public interface SinkRef<In>A
SinkRefallows sharing a "reference" to a
Sinkwith others, with the main purpose of crossing a network boundary. Usually obtaining a SinkRef would be done via Actor messaging, in which one system asks a remote one, to accept some data from it, and the remote one decides to accept the request to send data in a back-pressured streaming fashion -- using a sink ref.
To create a
SinkRefyou have to materialize the
Sinkthat you want to obtain a reference to by attaching it to a
Stream refs can be seen as Reactive Streams over network boundaries. See also
SourceRefwhich is the dual of a
For additional configuration see
reference.confas well as
Not for user extension.