PipeMessageHandler 类

定义

用于使用PipeReaderPipeWriter和接收消息的抽象基类。

public abstract class PipeMessageHandler : StreamJsonRpc.MessageHandlerBase
public abstract class PipeMessageHandler : StreamJsonRpc.MessageHandlerBase, StreamJsonRpc.Reflection.IJsonRpcMessageBufferManager
type PipeMessageHandler = class
    inherit MessageHandlerBase
type PipeMessageHandler = class
    inherit MessageHandlerBase
    interface IJsonRpcMessageBufferManager
Public MustInherit Class PipeMessageHandler
Inherits MessageHandlerBase
Public MustInherit Class PipeMessageHandler
Inherits MessageHandlerBase
Implements IJsonRpcMessageBufferManager
继承
PipeMessageHandler
派生
实现

构造函数

PipeMessageHandler(IDuplexPipe, IJsonRpcMessageFormatter)

初始化 PipeMessageHandler 类的新实例。

PipeMessageHandler(PipeWriter, PipeReader, IJsonRpcMessageFormatter)

初始化 PipeMessageHandler 类的新实例。

PipeMessageHandler(Stream, Stream, IJsonRpcMessageFormatter)

初始化 PipeMessageHandler 类的新实例。

属性

CanRead

获取一个值,该值指示此消息处理程序是否可以接收消息。

CanWrite

获取一个值,该值指示此消息处理程序是否可以发送消息。

DisposalToken

获取释放此实例时取消的令牌。

(继承自 MessageHandlerBase)
Formatter

获取用于消息序列化的格式化程序。

(继承自 MessageHandlerBase)
Reader

获取用于接收消息的读取器。

Writer

获取用于传输消息的编写器。

方法

Dispose()
已过时.

释放此实例,并取消任何挂起的读取或写入操作。

(继承自 MessageHandlerBase)
Dispose(Boolean)

释放此实例分配的资源,这些资源对于读取和写入都是常见的。

Dispose(Boolean)

释放此实例分配的资源,这些资源对于读取和写入都是常见的。

(继承自 MessageHandlerBase)
DisposeAsync()

释放此实例,并取消任何挂起的读取或写入操作。

(继承自 MessageHandlerBase)
DisposeReader()

释放此实例分配的资源,这些资源用于读取 (不写入) 。

DisposeReader()

释放此实例分配的资源,这些资源用于读取 (不写入) 。

(继承自 MessageHandlerBase)
DisposeWriter()

释放此实例分配的资源,这些资源用于写入 (不读取) 。

DisposeWriter()

释放此实例分配的资源,这些资源用于写入 (不读取) 。

(继承自 MessageHandlerBase)
FlushAsync(CancellationToken)

确保传送到此点的所有消息都路由到其目标,而不是坐在一些本地缓冲区中。

ReadAsync(CancellationToken)

从传输中读取不同的完整消息,并在必要时等待一条消息。

(继承自 MessageHandlerBase)
ReadAtLeastAsync(Int32, Boolean, CancellationToken)

Reader 读取,直到至少有指定的字节数可用。

ReadCoreAsync(CancellationToken)

读取非重复且完整的消息,并在必要时等待一条消息。

(继承自 MessageHandlerBase)
Write(JsonRpcMessage, CancellationToken)

将消息写入管道。

WriteAsync(JsonRpcMessage, CancellationToken)

将消息写入传输并刷新。

(继承自 MessageHandlerBase)
WriteCoreAsync(JsonRpcMessage, CancellationToken)

写入消息。

显式接口实现

IDisposableObservable.IsDisposed

获取一个值,该值指示是否已释放此实例。

(继承自 MessageHandlerBase)
IJsonRpcMessageBufferManager.DeserializationComplete(JsonRpcMessage)

通知释放保留的缓冲区以反序列化消息的有效负载是安全的,因为所有反序列化尝试都已完成。

适用于