Class AddFileToDfsRequestObserver

The request handler to add a file to the DFS

Inheritance
System.Object
MessageObserverBase
RequestObserverBase<AddFileToDfsRequest, AddFileToDfsResponse>
AddFileToDfsRequestObserver
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 AddFileToDfsRequestObserver : RequestObserverBase<AddFileToDfsRequest, AddFileToDfsResponse>, IDisposable, IRequestMessageObserver, IRpcRequestObserver, IMessageObserver, IObserver<IObserverDto<ProtocolMessage>>

Constructors

| Improve this Doc View Source

AddFileToDfsRequestObserver(IDfs, IPeerSettings, IDownloadFileTransferFactory, ILogger)

Initializes a new instance of the AddFileToDfsRequestObserver class.

Declaration
public AddFileToDfsRequestObserver(IDfs dfs, IPeerSettings peerSettings, IDownloadFileTransferFactory fileTransferFactory, ILogger logger)
Parameters
Type Name Description
IDfs dfs

The DFS.
IPeerSettings peerSettings
IDownloadFileTransferFactory fileTransferFactory

The download file transfer factory.
ILogger logger

The logger.

Methods

| Improve this Doc View Source

HandleRequest(AddFileToDfsRequest, IChannelHandlerContext, PeerId, ICorrelationId)

Declaration
protected override AddFileToDfsResponse HandleRequest(AddFileToDfsRequest addFileToDfsRequest, IChannelHandlerContext channelHandlerContext, PeerId senderPeerId, ICorrelationId correlationId)
Parameters
Type Name Description
AddFileToDfsRequest addFileToDfsRequest
IChannelHandlerContext channelHandlerContext
PeerId senderPeerId
ICorrelationId correlationId
Returns
Type Description
AddFileToDfsResponse

Implements

System.IDisposable
System.IObserver<T>

See Also