GoldenGateConnectionManager / com.fitbit.goldengate.node.stack / StackPeer / connection

connection

@Synchronized fun connection(): Observable<PeerConnectionStatus>

Overrides Peer.connection

Get a reference to the connection of the Peer. If the Peer is not yet connected, it will connect upon subscription. The returned Observable will be shared for all callers connection until the connection is lost or disconnected. A successive call after disconnected will return a new Observable. Disposing the returned Observable will NOT disconnect the connection. This method should be Synchronized with disconnect and close

Return
an Observable<PeerConnectionStatus>: