как использовать многоадресную рассылку сообщений с объектами поведения?

В общем, нам нужна функциональность предмета поведения. Но только при первой подписке мы должны отправить подписку на сервер в REST. И чтобы отправить отказ от подписки при последнем отказе от подписки, и все поздние подписавшиеся наблюдатели будут получать последний json, полученный с первого. Могу ли я сделать это с помощью операторов rxjs и как? или я использую пользовательский Obserbale?

в настоящее время настраиваемый код для этого таков:

public observable: Observable<TPattern> = new Observable((observer: Observer<TPattern>) => {
 this._observers.push(observer);
 if (this._observers.length === 1) {
  this._subscription = this.httpRequestStream$
    .pipe(
      map((jsonObj: any) => {
        this._pattern = jsonObj.Data;
        return this._pattern;
      })
    )
    .subscribe(
      (data) => this._observers.forEach((obs) => obs.next(data)),
      (error) => this._observers.forEach((obs) => obs.error(error)),
      () => this._observers.forEach((obs) => obs.complete())
    );
}
if (this._pattern !== null) {
  observer.next(this._pattern); // send last updated array
}
return () => {
  const index: number = this._observers.findIndex((element) => element === observer);
  this._observers.splice(index, 1);
  if (this._observers.length === 0) {
    this._subscription.unsubscribe();
    this._pattern = null; // clear pattern when unsubscribed
  }
};

});