You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Implement the take and possible other variants (e.g. take(Duration), takeUntil(Predicate<T>), etc...) for the Observable API !
For API inspiration, it would be nice to stay close to Reactor.
Note:
Observable don't have a "complete" operation. Maybe the ConnectorObservableValue could help since when the Observable should stop emitting we could call the ConnectorObservableValue.disconnect() method.
The text was updated successfully, but these errors were encountered:
Implement the
take
and possible other variants (e.g.take(Duration)
,takeUntil(Predicate<T>)
, etc...) for theObservable
API !For API inspiration, it would be nice to stay close to Reactor.
Note:
Observable
don't have a "complete" operation. Maybe theConnectorObservableValue
could help since when theObservable
should stop emitting we could call theConnectorObservableValue.disconnect()
method.The text was updated successfully, but these errors were encountered: