 | Flow<TIn, TOut, TMat> Methods |
The Flow< TIn, TOut, TMat> generic type exposes the following members.
Methods| Name | Description | |
|---|---|---|
 | AddAttributes |
Add the given attributes to this Flow<TIn, TOut, TMat>.
Further calls to WithAttributes(Attributes)
will not remove these attributes. Note that this
operation has no effect on an empty Flow (because the attributes apply
only to the contained processing stages).
|
| Async |
Put an asynchronous boundary around this Source.
|
| ConcatMaterialized<TMat2, TMat3> |
Concatenate the given to this , meaning that once this
Flow’s input is exhausted and all result elements have been generated,
the Source’s elements will be produced.
Note that the is materialized together with this Flow and just kept
from producing elements by asserting back-pressure until its time comes.
If this gets upstream error - no elements from the given will be pulled.
@see .
It is recommended to use the internally optimized Left< TLeft, TRight> (TLeft, TRight) and Right< TLeft, TRight> (TLeft, TRight) combiners
where appropriate instead of manually writing functions that pass through one of the values.
|
| Equals | Determines whether the specified object is equal to the current object. (Inherited from Object.) |
 | Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) |
| GetHashCode | Serves as the default hash function. (Inherited from Object.) |
| GetType | Gets the Type of the current instance. (Inherited from Object.) |
| Join<TMat2>(IGraph<FlowShape<TOut, TIn>, TMat2>) |
Join this Flow< TIn, TOut, TMat> to another Flow<TIn, TOut, TMat>, by cross connecting the inputs and outputs,
creating a IRunnableGraph<TMat>.
The materialized value of the combined Flow< TIn, TOut, TMat> will be the materialized
value of the current flow (ignoring the other Flow’s value), use
JoinMaterialized< TMat2, TMat3> (IGraph< FlowShape< TOut, TIn> , TMat2> , Func< TMat, TMat2, TMat3> ) if a different strategy is needed.
|
| Join<TIn2, TOut2, TMat2>(IGraph<BidiShape<TOut, TOut2, TIn2, TIn>, TMat2>) |
TBD
|
| JoinMaterialized<TMat2, TMat3>(IGraph<FlowShape<TOut, TIn>, TMat2>, Func<TMat, TMat2, TMat3>) |
Join this Flow< TIn, TOut, TMat> to another Flow<TIn, TOut, TMat>, by cross connecting the inputs and outputs, creating a IRunnableGraph< TMat>
The combine function is used to compose the materialized values of this flow and that
Flow into the materialized value of the resulting Flow.
|
| JoinMaterialized<TIn2, TOut2, TMat2, TMatRes>(IGraph<BidiShape<TOut, TOut2, TIn2, TIn>, TMat2>, Func<TMat, TMat2, TMatRes>) |
TBD
|
| MapMaterializedValue<TMat2> |
Transform the materialized value of this Flow, leaving all other properties as they were.
|
| MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) |
| Named |
Add a name attribute to this Flow.
|
| RunWith<TMat1, TMat2> |
Connect the Source< TOut, TMat> to this Flow< TIn, TOut, TMat> and then connect it to the Sink< TIn, TMat> and run it.
The returned tuple contains the materialized values of the source and sink, e.g. the ISubscriber
of a AsSubscriber< T> () and IPublisher of a Publisher<TIn>().
|
| To<TMat2> |
Connect this Flow< TIn, TOut, TMat> to a Sink<TIn, TMat>, concatenating the processing steps of both.
The materialized value of the combined Sink< TIn, TMat> will be the materialized
value of the current flow (ignoring the given Sink’s value), use
ToMaterialized< TMat2, TMat3> (IGraph< SinkShape< TOut> , TMat2> , Func< TMat, TMat2, TMat3> ) if a different strategy is needed.
|
| ToMaterialized<TMat2, TMat3> |
Connect this Flow< TIn, TOut, TMat> to a Sink<TIn, TMat>, concatenating the processing steps of both.
The combine function is used to compose the materialized values of this flow and that
Sink into the materialized value of the resulting Sink.
It is recommended to use the internally optimized Left< TLeft, TRight> (TLeft, TRight) and Right< TLeft, TRight> (TLeft, TRight) combiners
where appropriate instead of manually writing functions that pass through one of the values.
|
| ToProcessor |
Converts this Flow to a IRunnableGraph< TMat> that materializes to a Reactive Streams IProcessor
which implements the operations encapsulated by this Flow. Every materialization results in a new Processor
instance, i.e. the returned IRunnableGraph< TMat> is reusable.
|
| ToString |
TBD
(Overrides Object.ToString().) |
| Via<T2, TMat2> |
Transform this Flow< TIn, TOut, TMat> by appending the given processing steps.
The materialized value of the combined Flow< TIn, TOut, TMat> will be the materialized
value of the current flow (ignoring the other flow’s value), use
ViaMaterialized< TOut2, TMat2, TMat3> (IGraph< FlowShape< TOut, TOut2> , TMat2> , Func< TMat, TMat2, TMat3> ) if a different strategy is needed.
|
| ViaMaterialized<TOut2, TMat2, TMat3> |
Transform this Flow< TIn, TOut, TMat> by appending the given processing steps.
The combine function is used to compose the materialized values of this flow and that
flow into the materialized value of the resulting Flow.
|
| WithAttributes |
Change the attributes of this Flow< TIn, TOut, TMat> to the given ones. Note that this
operation has no effect on an empty Flow (because the attributes apply
only to the contained processing stages).
|
Extension Methods| Name | Description | |
|---|---|---|
 | AsInstanceOf<T> |
TBD
(Defined by Extensions.) |
| Match() | Overloaded.
Matches the specified target.
(Defined by PatternMatch.) |
| Match<T>() | Overloaded.
Matches the specified target and return a result of target processing.
(Defined by PatternMatch.) |
See Also