Class RemoteSubscriptionPipeline<TEvent>

Namespace

DotBoxD.Plugins.Runtime

Assembly

DotBoxD.Plugins.dll

public sealed class RemoteSubscriptionPipeline<TEvent>

Type Parameters

TEvent

Inheritance

object

RemoteSubscriptionPipeline<TEvent>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Run(Action<TEvent, HookContext>)

public RemoteSubscriptionPipeline<TEvent> Run(Action<TEvent, HookContext> handler)

Parameters

handler Action<TEvent, HookContext>

Returns

RemoteSubscriptionPipeline<TEvent>

Run(Action<TEvent>)

public RemoteSubscriptionPipeline<TEvent> Run(Action<TEvent> handler)

Parameters

handler Action<TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

Run(Func<TEvent, HookContext, ValueTask>)

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

Parameters

handler Func<TEvent, HookContext, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent>

Run(Func<TEvent, ValueTask>)

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

Parameters

handler Func<TEvent, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent>

RunLocal(Action<TEvent, HookContext>)

public RemoteSubscriptionPipeline<TEvent> RunLocal(Action<TEvent, HookContext> handler)

Parameters

handler Action<TEvent, HookContext>

Returns

RemoteSubscriptionPipeline<TEvent>

RunLocal(Action<TEvent>)

public RemoteSubscriptionPipeline<TEvent> RunLocal(Action<TEvent> handler)

Parameters

handler Action<TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

RunLocal(Func<TEvent, HookContext, ValueTask>)

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

Parameters

handler Func<TEvent, HookContext, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent>

RunLocal(Func<TEvent, ValueTask>)

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

Parameters

handler Func<TEvent, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent>

Select<TNext>(Func<TEvent, HookContext, TNext>)

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

Parameters

projection Func<TEvent, HookContext, TNext>

Returns

RemoteSubscriptionStage<TEvent, TNext>

Type Parameters

TNext

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

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

Parameters

projection Func<TEvent, TNext>

Returns

RemoteSubscriptionStage<TEvent, TNext>

Type Parameters

TNext

UseGeneratedChain(PluginPackage)

public RemoteSubscriptionPipeline<TEvent> UseGeneratedChain(PluginPackage package)

Parameters

package PluginPackage

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Action<TEvent, HookContext>)

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

Parameters

package PluginPackage

handler Action<TEvent, HookContext>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Action<TEvent, HookContext>, Func<KernelRpcValue, TEvent>)

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

Parameters

package PluginPackage

handler Action<TEvent, HookContext>

decoder Func<KernelRpcValue, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Action<TEvent, HookContext>, Func<ReadOnlyMemory<byte>, TEvent>)

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

Parameters

package PluginPackage

handler Action<TEvent, HookContext>

decoder Func<ReadOnlyMemory<byte>, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Action<TEvent>)

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

Parameters

package PluginPackage

handler Action<TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

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

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

Parameters

package PluginPackage

handler Action<TEvent>

decoder Func<KernelRpcValue, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

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

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

Parameters

package PluginPackage

handler Action<TEvent>

decoder Func<ReadOnlyMemory<byte>, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Func<TEvent, HookContext, ValueTask>)

Installs a lowered RunLocal subscription chain: the lowered Where/Select filter+projection installs server-side and the native handler is registered against the returned subscription id to receive each filtered, projected value pushed back over IPC.

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

Parameters

package PluginPackage

handler Func<TEvent, HookContext, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Func<TEvent, HookContext, ValueTask>, Func<KernelRpcValue, TEvent>)

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

Parameters

package PluginPackage

handler Func<TEvent, HookContext, ValueTask>

decoder Func<KernelRpcValue, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Func<TEvent, HookContext, ValueTask>, Func<ReadOnlyMemory<byte>, TEvent>)

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

Parameters

package PluginPackage

handler Func<TEvent, HookContext, ValueTask>

decoder Func<ReadOnlyMemory<byte>, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

UseGeneratedLocalChain(PluginPackage, Func<TEvent, ValueTask>)

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

Parameters

package PluginPackage

handler Func<TEvent, ValueTask>

Returns

RemoteSubscriptionPipeline<TEvent>

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

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

Parameters

package PluginPackage

handler Func<TEvent, ValueTask>

decoder Func<KernelRpcValue, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

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

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

Parameters

package PluginPackage

handler Func<TEvent, ValueTask>

decoder Func<ReadOnlyMemory<byte>, TEvent>

Returns

RemoteSubscriptionPipeline<TEvent>

Use<TKernel>()

public RemoteSubscriptionPipeline<TEvent> Use<TKernel>() where TKernel : class

Returns

RemoteSubscriptionPipeline<TEvent>

Type Parameters

TKernel

Where(Func<TEvent, HookContext, bool>)

public RemoteSubscriptionPipeline<TEvent> Where(Func<TEvent, HookContext, bool> filter)

Parameters

filter Func<TEvent, HookContext, bool>

Returns

RemoteSubscriptionPipeline<TEvent>

Where(Func<TEvent, bool>)

public RemoteSubscriptionPipeline<TEvent> Where(Func<TEvent, bool> filter)

Parameters

filter Func<TEvent, bool>

Returns

RemoteSubscriptionPipeline<TEvent>