Как создать Observable из темы, не подвергая субъекта потребителям в RxJs v5

Question

Я пытаюсь вернуть наблюдаемое из функции, которая использует Rx.Subject внутри. Конечно, как и с любым хорошим API, детали реализации должны быть полностью абстрагированы от потребителя. Однако, используя Subject.asObservable(), любой потребитель может выдать новые значения всем наблюдателям.

Пример:

const subject = new Rx.Subject(); 
const observable = subject.asObservable(); 

observable.source === subject; // true 

observable.forEach(value => console.log(value)); 
observable.source.next('Hello'); 
// Causes the forEach above to print "Hello" 

Так что мой вопрос, есть ли встроенный образом, чтобы выставить наблюдаемые потребитель без предоставления им доступ к исходному вопросу? Если это явно плохой дизайн на части RxJs.

ПРИМЕЧАНИЕ: Это для RxJS v5

Answer 1

Единственный способ, который я знаю, чтобы поистине инкапсулировать это было бы подписаться на эту тему внутри вашей функции и и у другого (либо предметом или пользовательских obervable), который испускает эти значения.

Но любой оператор (даже операторы создания, такие как Observable.combineLatest(subject)) имеет some способ доступа к источнику.

Другой способ «решить» это было бы использовать машинопись, потому что TS-компилятор скажет вам, что вы не можете получить доступ к защищенному свойство source на Observable, так как он не является публичным атрибутом: https://github.com/ReactiveX/rxjs/blob/master/src/Observable.ts#L30 - конечно, в ES5 нет такой вещи, как «защищенная», и поэтому она будет доступна через консоль, например