Class StreamPipelineChainExtensions

Inheritance

object

StreamPipelineChainExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Glitch9.IO.Networking.RESTApi

Assembly: Glitch9.IO.dll

Syntax

public static class StreamPipelineChainExtensions

Methods

| Edit this page View Source

Aggregate<TIn, TOut>(IStreamStage<TIn, TOut>, IStreamAggregator<TOut>)

Declaration

public static IStreamStage<TIn, TOut> Aggregate<TIn, TOut>(this IStreamStage<TIn, TOut> stage, IStreamAggregator<TOut> aggregator)

Parameters

Type	Name	Description
IStreamStage<TIn, TOut>	stage
IStreamAggregator<TOut>	aggregator

Returns

Type	Description
IStreamStage<TIn, TOut>

Type Parameters

Name	Description
TIn
TOut

| Edit this page View Source

Cast<TIn, TOut1, TOut2>(IStreamStage<TIn, TOut1>)

Declaration

public static IStreamStage<TIn, TOut2> Cast<TIn, TOut1, TOut2>(this IStreamStage<TIn, TOut1> first) where TOut1 : TOut2

Parameters

Type	Name	Description
IStreamStage<TIn, TOut1>	first

Returns

Type	Description
IStreamStage<TIn, TOut2>

Type Parameters

Name	Description
TIn
TOut1
TOut2

| Edit this page View Source

Finalize<TWire, TEvent, TResult>(IStreamStage<TWire, TEvent>, IStreamFinalizer<TResult>)

Declaration

public static IStreamPipeline<TWire, TEvent, TResult> Finalize<TWire, TEvent, TResult>(this IStreamStage<TWire, TEvent> stage, IStreamFinalizer<TResult> finalizer) where TEvent : IEvent where TResult : IResult

Parameters

Type	Name	Description
IStreamStage<TWire, TEvent>	stage
IStreamFinalizer<TResult>	finalizer

Returns

Type	Description
IStreamPipeline<TWire, TEvent, TResult>

Type Parameters

Name	Description
TWire
TEvent
TResult

| Edit this page View Source

Parse<TIn, TOut1, TOut2>(IStreamStage<TIn, TOut1>, IStreamStage<TOut1, TOut2>)

Declaration

public static IStreamStage<TIn, TOut2> Parse<TIn, TOut1, TOut2>(this IStreamStage<TIn, TOut1> first, IStreamStage<TOut1, TOut2> second)

Parameters

Type	Name	Description
IStreamStage<TIn, TOut1>	first
IStreamStage<TOut1, TOut2>	second

Returns

Type	Description
IStreamStage<TIn, TOut2>

Type Parameters

Name	Description
TIn
TOut1
TOut2

| Edit this page View Source

Project<TOut1, TOut2>(IStreamStage<string, TOut1>)

Declaration

public static IStreamStage<string, TOut2> Project<TOut1, TOut2>(this IStreamStage<string, TOut1> parser) where TOut1 : IProjector<TOut2>

Parameters

Type	Name	Description
IStreamStage<string, TOut1>	parser

Returns

Type	Description
IStreamStage<string, TOut2>

Type Parameters

Name	Description
TOut1
TOut2

| Edit this page View Source

Project<TIn, TOut1, TOut2>(IStreamStage<TIn, TOut1>)

Declaration

public static IStreamStage<TIn, TOut2> Project<TIn, TOut1, TOut2>(this IStreamStage<TIn, TOut1> parser) where TOut1 : IProjector<TOut2>

Parameters

Type	Name	Description
IStreamStage<TIn, TOut1>	parser

Returns

Type	Description
IStreamStage<TIn, TOut2>

Type Parameters

Name	Description
TIn
TOut1
TOut2

| Edit this page View Source

Sequence<TIn, TOut>(IStreamStage<TIn, TOut>)

Declaration

public static IStreamStage<TIn, TOut> Sequence<TIn, TOut>(this IStreamStage<TIn, TOut> stage) where TOut : ISequencableEvent

Parameters

Type	Name	Description
IStreamStage<TIn, TOut>	stage

Returns

Type	Description
IStreamStage<TIn, TOut>

Type Parameters

Name	Description
TIn
TOut

| Edit this page View Source

Transform<TIn, TOut1, TOut2>(IStreamStage<TIn, TOut1>, IStreamStage<TOut1, TOut2>)

Declaration

public static IStreamStage<TIn, TOut2> Transform<TIn, TOut1, TOut2>(this IStreamStage<TIn, TOut1> first, IStreamStage<TOut1, TOut2> second)

Parameters

Type	Name	Description
IStreamStage<TIn, TOut1>	first
IStreamStage<TOut1, TOut2>	second

Returns

Type	Description
IStreamStage<TIn, TOut2>

Type Parameters

Name	Description
TIn
TOut1
TOut2

| Edit this page View Source

WrapDelta<TIn, TOut>(IStreamStage<TIn, TOut>)

Declaration

public static IStreamStage<TIn, Delta<TOut>> WrapDelta<TIn, TOut>(this IStreamStage<TIn, TOut> inner)

Parameters

Type	Name	Description
IStreamStage<TIn, TOut>	inner

Returns

Type	Description
IStreamStage<TIn, Delta<TOut>>

Type Parameters

Name	Description
TIn
TOut