hu.akarnokd.reactive4java.base

Interface ConnectableObservable<T>

Type Parameters:

T - the element type

All Superinterfaces:

Observable<T>

All Known Implementing Classes:

DefaultConnectableObservable

public interface ConnectableObservable<T>
extends Observable<T>

An observable which can be connected, reconnected or disconnected to a source observable.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	connect() Connects the wrapper to its source.

Methods inherited from interface hu.akarnokd.reactive4java.base.Observable

register

Method Detail

connect

java.io.Closeable connect()

Connects the wrapper to its source. All registered observers will receive values while this connection is active. Closing the connection will stop the observers from receiving events, but they won't be deregistered. Connecting to an already connected source is a no-op.

Returns:

the handler to close the connection