// 定义观察者接口
interface Observer {
  update(news: string): void;
}

// 定义主题接口
interface Subject {
  registerObserver(observer: Observer): void;
  removeObserver(observer: Observer): void;
  notifyObservers(): void;
}

// 具体主题：新闻发布者
class NewsPublisher implements Subject {
  private observers: Observer[] = [];
  private latestNews: string = '';

  registerObserver(observer: Observer): void {
    if (!this.observers.includes(observer)) {
      this.observers.push(observer);
    }
  }

  removeObserver(observer: Observer): void {
    const index = this.observers.indexOf(observer);
    if (index !== -1) {
      this.observers.splice(index, 1);
    }
  }

  notifyObservers(): void {
    this.observers.forEach(observer => observer.update(this.latestNews));
  }

  // 发布新闻并通知所有观察者
  publishNews(news: string): void {
    this.latestNews = news;
    this.notifyObservers();
  }
}

// 具体观察者：新闻订阅者
class NewsSubscriber implements Observer {
  private name: string;

  constructor(name: string) {
    this.name = name;
  }

  update(news: string): void {
    console.log(`${this.name} 收到新闻: ${news}`);
  }
}

// 使用示例
const publisher = new NewsPublisher();

const subscriber1 = new NewsSubscriber('张三');
const subscriber2 = new NewsSubscriber('李四');
const subscriber3 = new NewsSubscriber('王五');

publisher.registerObserver(subscriber1);
publisher.registerObserver(subscriber2);
publisher.registerObserver(subscriber3);

publisher.publishNews('今天天气晴朗！');
// 输出:
// 张三 收到新闻: 今天天气晴朗！
// 李四 收到新闻: 今天天气晴朗！
// 王五 收到新闻: 今天天气晴朗！

publisher.removeObserver(subscriber2);
publisher.publishNews('李四已取消订阅，不会收到这条新闻');
// 输出:
// 张三 收到新闻: 李四已取消订阅，不会收到这条新闻
// 王五 收到新闻: 李四已取消订阅，不会收到这条新闻