return some? Я просто думал, что нормальный способ взаимодействия тут subscriber.next и функция не должна ничего возвращать и в этом нет смысла. Но тогда зачем?
new Observable<blabla>(subscriber => {
setTimeout(() => {
subscriber.next(blabla);
subscriber.complete();
}, 1000);
return some;
});
А ts не ругается? Сигнатура у конструктора подразумевает возврат?
Это функция. Teardown логика
А, типа для отписки возвращаем колбэк?
Ни, тут исходный Observable, который до этого всяко операторами пиннали, обратывали. Нифункция, но весь код увидеть вы явно не хотите, там запутано и много, шопрямужас.
constructor(subscribe?: (this: Observable<T>, subscriber: Subscriber<T>) => TeardownLogic) { if (subscribe) { this._subscribe = subscribe; } }
protected _subscribe(subscriber: Subscriber<any>): TeardownLogic { return this.source?.subscribe(subscriber); }
Обсуждают сегодня