Returns a Future
that will complete when this stream stop
s.
Returns a Future
that will complete when this stream stop
s. The
resulting value will be a rough estimate (System.currentTimeMillis
)
of when the stream ended. If the stream never ends, the resulting
Future will never complete.
A Future
containing a time stamp describing when this stream stopped.
Returns a Future
that will complete with the value of the last
event fired by this stream.
Returns a Future
that will complete with the value of the last
event fired by this stream. If the stream is stopped or becomes stopped
before firing an event, the Future will fail with a NoSuchElementException
.
A Future
containing the last event fired by this stream.
Returns a Future
that will complete with the value of the next
event fired by this stream.
Returns a Future
that will complete with the value of the next
event fired by this stream. If the stream is stopped, or if it
stops before firing an event, the Future will fail with a
NoSuchElementException
.
A Future
containing the next event fired by this stream.
(eventStreamFutures: StringAdd).self
(eventStreamFutures: StringFormat).self
(eventStreamFutures: ArrowAssoc[EventStreamFutures[A]]).x
(Since version 2.10.0) Use leftOfArrow
instead
(eventStreamFutures: Ensuring[EventStreamFutures[A]]).x
(Since version 2.10.0) Use resultOfEnsuring
instead