Class ObservableStreamMessageArgumentResolver

Resolves the parameters declared as IMessageStreamObservable<TMessage> where TMessage is compatible with the type of the message being published.

Inheritance
System.Object
ObservableStreamMessageArgumentResolver
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Silverback.Messaging.Subscribers.ArgumentResolvers
Assembly: Silverback.Core.Rx.dll
Syntax
public class ObservableStreamMessageArgumentResolver : IStreamEnumerableMessageArgumentResolver, IMessageArgumentResolver, IArgumentResolver

Methods

| Improve this doc View source

CanResolve(Type)

Declaration
public bool CanResolve(Type parameterType)
Parameters
Type Name Description
System.Type parameterType
Returns
Type Description
System.Boolean
| Improve this doc View source

GetMessageType(Type)

Declaration
public Type GetMessageType(Type parameterType)
Parameters
Type Name Description
System.Type parameterType
Returns
Type Description
System.Type
| Improve this doc View source

GetValue(IMessageStreamProvider, Type, IReadOnlyCollection<IMessageFilter>)

Declaration
public ILazyArgumentValue GetValue(IMessageStreamProvider streamProvider, Type targetMessageType, IReadOnlyCollection<IMessageFilter> filters = null)
Parameters
Type Name Description
IMessageStreamProvider streamProvider
System.Type targetMessageType
System.Collections.Generic.IReadOnlyCollection<IMessageFilter> filters
Returns
Type Description
ILazyArgumentValue

Implements