Как мне создать «тему» ​​F # Observable?

Question

В Rx я могу создать объект (что-то), например:

let s = new Subject<int>()

let subscription = 
  s.Subscribe (fun x -> 
    Console.WriteLine x
  )

s.OnNext 123

Объект является как наблюдаемым, так и наблюдателем.Это полезно при превращении обратных вызовов в потоки.

Что эквивалентно, если использовать встроенный модуль F # Observable?

Answer 1

В F # Snippets есть пример реализации:

Observable.Subject

Тип Subject реализует как IObserver, так и IObservable.Он функционально эквивалентен типу с тем же именем в библиотеке Reactive Extensions (Rx).

Answer 2

Вы сказали это:

Субъект является как наблюдаемым, так и наблюдателем.

Чтобы достичь эквивалента реализации Rx.NET, вам придетсяпредоставьте недостающие части, которые составляют интерфейс Subject.

Все значения в модуле Observable создают IObserver или возвращают не более двух IObservable с;это не имеет отношения к Subject с.