StreamMessageHandler 类

定义

用于通过读取和写入对象对来发送和接收消息的 Stream 抽象基类。

public abstract class StreamMessageHandler : StreamJsonRpc.MessageHandlerBase
type StreamMessageHandler = class
    inherit MessageHandlerBase
Public MustInherit Class StreamMessageHandler
Inherits MessageHandlerBase
继承
StreamMessageHandler

构造函数

StreamMessageHandler(Stream, Stream, IJsonRpcMessageFormatter)

初始化 StreamMessageHandler 类的新实例。

属性

CanRead

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

CanWrite

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

DisposalToken

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

(继承自 MessageHandlerBase)
Formatter

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

(继承自 MessageHandlerBase)
ReceivingStream

获取用于接收消息的流。 可能为 null。

SendingStream

获取用于传输消息的流。 可能为 null。

方法

Dispose()
已过时.

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

(继承自 MessageHandlerBase)
Dispose(Boolean)

释放此实例分配的资源。

DisposeAsync()

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

(继承自 MessageHandlerBase)
DisposeReader()

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

(继承自 MessageHandlerBase)
DisposeWriter()

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

(继承自 MessageHandlerBase)
FlushAsync(CancellationToken)

FlushAsync()如果使用备用传输,SendingStream则调用或等效的发送流。

ReadAsync(CancellationToken)

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

(继承自 MessageHandlerBase)
ReadCoreAsync(CancellationToken)

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

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

将消息写入传输并刷新。

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

写入消息。

(继承自 MessageHandlerBase)

显式接口实现

IDisposableObservable.IsDisposed

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

(继承自 MessageHandlerBase)

适用于