Skip to main content
Module

x/rxjs/mod.ts>ConnectableObservable

Deno port of RXJS
ziv/deno-rxjs
Latest
class ConnectableObservable
extends Observable<T>
Deprecated
Deprecated

Will be removed in v8. Use connectable to create a connectable observable. If you are using the refCount method of ConnectableObservable, use the share operator instead. Details: https://rxjs.dev/deprecations/multicasting

import { ConnectableObservable } from "https://deno.land/x/rxjs@v1.0.2/mod.ts";

Constructors

new
ConnectableObservable(source: Observable<T>, subjectFactory: () => Subject<T>)

Properties

protected
_connection: Subscription | null
protected
_refCount: number
protected
_subject: Subject<T> | null

Methods

protected
_subscribe(subscriber: Subscriber<T>)
protected
_teardown()
protected
getSubject(): Subject<T>
deprecated
connect(): Subscription
deprecated
refCount(): Observable<T>