CreateSink class¶

Summary¶

View source

The observer handed to create-style subscription factories: forwards until terminated, owns the factory's cancel resource, and optionally releases it when a downstream OnNext throws (the safe-create contract). The shared sink behind CreateSignal and CreateSafeSignal, usable by any implementation that hands an observer to a caller-supplied subscribe delegate.

classDiagram
class CreateSink~T~
class IDisposable {
    <>
}
IDisposable <|.. CreateSink~T~
class IObserver~T~ {
    <>
}
IObserver~T~ <|.. CreateSink~T~

Implements: IDisposable, IObserver

Constructors¶

Methods¶