Class RemoteSubscriptionStage<TEvent, TCurrent, TContext>

Namespace

DotBoxD.Plugins.Runtime.Subscriptions

Assembly

DotBoxD.Plugins.dll

public sealed class RemoteSubscriptionStage<TEvent, TCurrent, TContext>

Type Parameters

TEvent

TCurrent

TContext

Inheritance

object

RemoteSubscriptionStage<TEvent, TCurrent, TContext>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Run(Action<TCurrent, TContext>)

public RemoteSubscriptionPipeline<TEvent, TContext> Run(Action<TCurrent, TContext> handler)

Parameters

handler Action<TCurrent, TContext>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

Run(Action<TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> Run(Action<TCurrent> handler)

Parameters

handler Action<TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

Run(Func<TCurrent, ValueTask>)

public RemoteSubscriptionPipeline<TEvent, TContext> Run(Func<TCurrent, ValueTask> handler)

Parameters

handler Func<TCurrent, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

Run(Func<TCurrent, TContext, ValueTask>)

public RemoteSubscriptionPipeline<TEvent, TContext> Run(Func<TCurrent, TContext, ValueTask> handler)

Parameters

handler Func<TCurrent, TContext, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

RunLocal(Action<TCurrent, TContext>)

public RemoteSubscriptionPipeline<TEvent, TContext> RunLocal(Action<TCurrent, TContext> handler)

Parameters

handler Action<TCurrent, TContext>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

RunLocal(Action<TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> RunLocal(Action<TCurrent> handler)

Parameters

handler Action<TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

RunLocal(Func<TCurrent, ValueTask>)

public RemoteSubscriptionPipeline<TEvent, TContext> RunLocal(Func<TCurrent, ValueTask> handler)

Parameters

handler Func<TCurrent, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

RunLocal(Func<TCurrent, TContext, ValueTask>)

public RemoteSubscriptionPipeline<TEvent, TContext> RunLocal(Func<TCurrent, TContext, ValueTask> handler)

Parameters

handler Func<TCurrent, TContext, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

Select<TNext>(Func<TCurrent, TContext, TNext>)

public RemoteSubscriptionStage<TEvent, TNext, TContext> Select<TNext>(Func<TCurrent, TContext, TNext> projection)

Parameters

projection Func<TCurrent, TContext, TNext>

Returns

RemoteSubscriptionStage<TEvent, TNext, TContext>

Type Parameters

TNext

Select<TNext>(Func<TCurrent, TNext>)

public RemoteSubscriptionStage<TEvent, TNext, TContext> Select<TNext>(Func<TCurrent, TNext> projection)

Parameters

projection Func<TCurrent, TNext>

Returns

RemoteSubscriptionStage<TEvent, TNext, TContext>

Type Parameters

TNext

UseGeneratedChain(PluginPackage)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedChain(PluginPackage package)

Parameters

package PluginPackage

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Action<TCurrent, TContext>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Action<TCurrent, TContext> handler)

Parameters

package PluginPackage

handler Action<TCurrent, TContext>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Action<TCurrent, TContext>, Func<KernelRpcValue, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Action<TCurrent, TContext> handler, Func<KernelRpcValue, TCurrent> decoder)

Parameters

package PluginPackage

handler Action<TCurrent, TContext>

decoder Func<KernelRpcValue, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Action<TCurrent, TContext>, Func<ReadOnlyMemory<byte>, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Action<TCurrent, TContext> handler, Func<ReadOnlyMemory<byte>, TCurrent> decoder)

Parameters

package PluginPackage

handler Action<TCurrent, TContext>

decoder Func<ReadOnlyMemory<byte>, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Action<TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Action<TCurrent> handler)

Parameters

package PluginPackage

handler Action<TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Action<TCurrent>, Func<KernelRpcValue, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Action<TCurrent> handler, Func<KernelRpcValue, TCurrent> decoder)

Parameters

package PluginPackage

handler Action<TCurrent>

decoder Func<KernelRpcValue, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Action<TCurrent>, Func<ReadOnlyMemory<byte>, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Action<TCurrent> handler, Func<ReadOnlyMemory<byte>, TCurrent> decoder)

Parameters

package PluginPackage

handler Action<TCurrent>

decoder Func<ReadOnlyMemory<byte>, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Func<TCurrent, ValueTask>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Func<TCurrent, ValueTask> handler)

Parameters

package PluginPackage

handler Func<TCurrent, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Func<TCurrent, ValueTask>, Func<KernelRpcValue, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Func<TCurrent, ValueTask> handler, Func<KernelRpcValue, TCurrent> decoder)

Parameters

package PluginPackage

handler Func<TCurrent, ValueTask>

decoder Func<KernelRpcValue, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Func<TCurrent, ValueTask>, Func<ReadOnlyMemory<byte>, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Func<TCurrent, ValueTask> handler, Func<ReadOnlyMemory<byte>, TCurrent> decoder)

Parameters

package PluginPackage

handler Func<TCurrent, ValueTask>

decoder Func<ReadOnlyMemory<byte>, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Func<TCurrent, TContext, ValueTask>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Func<TCurrent, TContext, ValueTask> handler)

Parameters

package PluginPackage

handler Func<TCurrent, TContext, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Func<TCurrent, TContext, ValueTask>, Func<KernelRpcValue, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Func<TCurrent, TContext, ValueTask> handler, Func<KernelRpcValue, TCurrent> decoder)

Parameters

package PluginPackage

handler Func<TCurrent, TContext, ValueTask>

decoder Func<KernelRpcValue, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

UseGeneratedLocalChain(PluginPackage, Func<TCurrent, TContext, ValueTask>, Func<ReadOnlyMemory<byte>, TCurrent>)

public RemoteSubscriptionPipeline<TEvent, TContext> UseGeneratedLocalChain(PluginPackage package, Func<TCurrent, TContext, ValueTask> handler, Func<ReadOnlyMemory<byte>, TCurrent> decoder)

Parameters

package PluginPackage

handler Func<TCurrent, TContext, ValueTask>

decoder Func<ReadOnlyMemory<byte>, TCurrent>

Returns

RemoteSubscriptionPipeline<TEvent, TContext>

Where(Func<TCurrent, bool>)

public RemoteSubscriptionStage<TEvent, TCurrent, TContext> Where(Func<TCurrent, bool> filter)

Parameters

filter Func<TCurrent, bool>

Returns

RemoteSubscriptionStage<TEvent, TCurrent, TContext>

Where(Func<TCurrent, TContext, bool>)

public RemoteSubscriptionStage<TEvent, TCurrent, TContext> Where(Func<TCurrent, TContext, bool> filter)

Parameters

filter Func<TCurrent, TContext, bool>

Returns

RemoteSubscriptionStage<TEvent, TCurrent, TContext>