Interface IAsyncReactiveStreamProcess

Interface representing a stream in a reactive processing service.

Inherited Members
Namespace: Reaqtor.Metadata
Assembly: Reaqtor.Metadata.Model.dll
Syntax
public interface IAsyncReactiveStreamProcess : IAsyncReactiveProcessResource, IAsyncReactiveResource, IKnownResource, IExpressible, IAsyncDisposable

Methods

ToStream<TInput, TOutput>()

Gets a subject that can be used to interact with the active stream.

Declaration
IAsyncReactiveQubject<TInput, TOutput> ToStream<TInput, TOutput>()
Returns
Type Description
IAsyncReactiveQubject<TInput, TOutput>

Subject object to interact with the stream.
Type Parameters
Name Description
TInput

Type of the data received by the subject.
TOutput

Type of the data produced by the subject.
Remarks

Implementation of this method requires access to a client library that can communicate with the reactive processing service (beyond the metadata layer). An implementation is allowed to discover a communication mechanism on the fly rather than relying on any particular client library. This allows dynamic discovery of streams and their use, e.g. in federation and delegation scenarios.