RxJs. почему не работают две подписки на один observable?

Question

[KiBiLizard]

есть observable созданный из Subject:

private searchData$: Observable<ISearchData>;
    
    constructor (private conService: ConnectionService) {
        this.searchData$ = <Observable<ISearchData>>conService.messages.pipe(
            filter((message) => {
                return message.key === QUERYBASE.search.key;
            }),
            map ((message)=>{
                return message.data as ISearchData;
            })
        );
    }

есть метод который отправляет запрос, после которого в messages появляются те сообщения которые пройдут фильтр, и подписывается на searchData$

public startSearch(){
        let queryData: ISearchQueryData = ...

        this.searchDataSub = this.searchData$.subscribe(
            (data)=>{
                console.log("Get search data: ",data);
                if (data.hash !== this.lastHash) {
                    this.items = data.search;
                    this.lastHash = data.hash;
                }
                this.searchDone = data.done;
            }
        );
        const newSub = this.searchData$.pipe(
            delay(2000)
        ).subscribe(
            (data)=> {
                console.log("sub2", data);
                //!data.done && this.conService.search(queryData);
            }
        );

        this.conService.search(queryData);
    }

если вторую подписку выпилить - первая работает (в консоли появляется "Get search data: , ...", данные обрабатываются)
а если оставить обе, почему-то работает только вторая подписка!! (в консоли только "sub2, ...", данных нет)

Я конечно могу вставить костыль и оставить только первую подписку в которой через таймаут отправлять запрос, но блин все учебники говорят о том что можно делать два .subscribe на один observable, и без всяких выкрутасов, так почему у меня оно не работает?

.pipe убирать пробовала, та же дичь, работает только вторая подписка:

this.searchDataSub = this.searchData$.subscribe(
            (data)=>{
                console.log("Get search data: ",data);
                /*...*/
            }
        );
        const newSub = this.searchData$.subscribe(
            (data)=> {
                console.log("sub2", data);
                //...
            }
        );

так в консоли только sub2

Comments

[Даша Циклаури]

отличия subject от observable в том что в первом случае создается одна подписка, а во втором на каждый вызов subscribe

[Lideeen]

А можно код ConnectionService?

[KiBiLizard]

Lideeen,

export class ConnectionService {
    public messages: Subject<IWSMessage>;

    constructor (private wsService:WebsocketService) {
...
        this.messages = <Subject<IWSMessage>>wsService.connect(CONNECT_URL).pipe(
            map((response: MessageEvent) => {
                let data = JSON.parse(response.data);
                console.log("WS Get data:",data);
                return {
                    key: data.key,
                    status: data.status,
                    data: data.data 
                };
            })
        )
...
    }
...
}

[KiBiLizard]

Даша Циклаури, пробовала делать searchData$ и subject и observable - ситуация та же

[Даша Циклаури]

KiBiLizard, так у тебя в любом случае получается Observable не вижу где ты его шаришь .share()

[Даша Циклаури]

KiBiLizard, эту статью нужно читать всем кто начинает работать с Рх
https://medium.com/@benlesh/hot-vs-cold-observable...
она 2016 года, но похожа нужна и в 2019 :D

[KiBiLizard]

Даша Циклаури, вроде дошло, спасибо)

Answer 1

[Даша Циклаури]

Hot vs cold observables