EsNullStreamSink
Description
An <EsStreamSink> that discards all events.
The sink silently drops events until #close is called, at which point it raises <EsAsyncStateError>s when events are added. This is the same behavior as a sink whose remote end has closed, such as when a socket connection has been closed.
This can be used when a sink is needed but no events are actually intended to be added. The
<EsNullStreamSink> error creational methods can be used to represent errors when creating a sink, since
EsStreamSink>>done exposes sink errors. For example:
["<create sink>"] on: Exception do: [:ex | EsNullStreamSink error: 'error']
Instance State
• done: <EsFuture>
• closed: <Boolean>
• addingStream: <EsStream>
Class Methods
done:
Creates a null sink.
If @done is passed, it's used as the [EsStreamSink done] future. Otherwise, a
completed future is used.
Arguments:
done - <EsFuture>
Answers:
<EsNullStreamSink>
error:
Creates a null sink whose `done` future emits an @error
Note that this error will not be considered uncaught.
Arguments:
error - <Object>
Answers:
<EsNullStreamSink>
error:stackTrace:
Creates a null sink whose `done` future emits an @error
Note that this error will not be considered uncaught.
Arguments:
error - <Object>
stackTrace - <EsAsyncStackTrace>
Answers:
<EsNullStreamSink>
new
Creates a null sink with a completed (with nil) future.
Answers:
<EsNullStreamSink>
Instance Methods
addError:stackTrace:
No comment
Last modified date: 04/21/2022