| SinkAsPublisherTIn Method |
A
SinkTIn, TMat that materializes into a
IPublisher.
If
fanout is true, the materialized
IPublisher will support multiple
ISubscriber`s and
the size of the
MaxInputBufferSize configured for this stage becomes the maximum number of elements that
the fastest
ISubscriber can be ahead of the slowest one before slowing
the processing down due to back pressure.
If
fanout is false then the materialized
IPublisher will only support a single
ISubscriber and
reject any additional
ISubscriber`s.
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax public static Sink<TIn, IPublisher<TIn>> AsPublisher<TIn>(
bool fanout
)
static member AsPublisher :
fanout : bool -> Sink<'TIn, IPublisher<'TIn>>
Parameters
- fanout
- Type: SystemBoolean
TBD
Type Parameters
- TIn
- TBD
Return Value
Type:
SinkTIn,
IPublisherTInTBD
See Also