Class GetFileFromDfsRequestObserver

The request handler to get a file from the DFS

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<GetFileFromDfsRequest, GetFileFromDfsResponse>
GetFileFromDfsRequestObserver
Implements
System.IDisposable
System.IObserver<IObserverDto<ProtocolMessage>>
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: Catalyst.Core.Modules.Rpc.Server.IO.Observers
Assembly: Catalyst.Core.Modules.Rpc.Server.dll
Syntax
public sealed class GetFileFromDfsRequestObserver : RequestObserverBase<GetFileFromDfsRequest, GetFileFromDfsResponse>, IDisposable, IRequestMessageObserver, IRpcRequestObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Constructors

| Improve this Doc View Source

GetFileFromDfsRequestObserver(IDfs, IHashProvider, IPeerSettings, IUploadFileTransferFactory, ILogger)

Initializes a new instance of the AddFileToDfsRequestObserver class.

Declaration
public GetFileFromDfsRequestObserver(IDfs dfs, IHashProvider hashProvider, IPeerSettings peerSettings, IUploadFileTransferFactory fileTransferFactory, ILogger logger)
Parameters
Type Name Description
IDfs dfs

The DFS.
IHashProvider hashProvider
IPeerSettings peerSettings
IUploadFileTransferFactory fileTransferFactory

The upload file transfer factory.
ILogger logger

The logger.

Methods

| Improve this Doc View Source

HandleRequest(GetFileFromDfsRequest, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected override GetFileFromDfsResponse HandleRequest(GetFileFromDfsRequest getFileFromDfsRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
GetFileFromDfsRequest getFileFromDfsRequest
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
GetFileFromDfsResponse
| Improve this Doc View Source

OnNext(IObserverDto<ProtocolMessage>)

Declaration
public override void OnNext(IObserverDto<ProtocolMessage> messageDto)
Parameters
Type Name Description
IObserverDto<ProtocolMessage> messageDto

Implements

System.IDisposable
System.IObserver<T>

See Also