StreamInteropRxJS

@mvuijs/core / rx / StreamInteropRxJS

StreamInteropRxJS<T> #

<T> object

{
    subscribe: (obs: ObserverDefinitionInterop<T>) => {
        unsubscribe: () => void;
    };
}

Stream interop with RxJS.

We cannot just use StreamInterop because of the way that RxJS implements Symbol.observable. It works with plain js but typescript gets confused.

Type parameters #

  • T

Type declaration #

Member Type
subscribe (obs: ObserverDefinitionInterop <T>) => { unsubscribe: () => void; }

Defined in: packages/core/src/rx/operators/creation/from.ts:21