从transporter.sendMail创建可观察对象

npm install nodemailer rxjs

const { Observable } = require('rxjs');
const nodemailer = require('nodemailer');

const transporter = nodemailer.createTransport({
  // 配置邮件传输
});

const sendMailObservable = new Observable((observer) => {
  transporter.sendMail({
    // 邮件配置
  }, (error, info) => {
    if (error) {
      observer.error(error); // 发送错误
    } else {
      observer.next(info); // 发送成功
      observer.complete(); // 完成观察
    }
  });
});

// 订阅可观察对象
sendMailObservable.subscribe({
  next: (info) => {
    console.log('邮件发送成功:', info);
  },
  error: (error) => {
    console.error('邮件发送失败:', error);
  },
  complete: () => {
    console.log('观察完成');
  }
});