PipeMessageHandler 类

定义

命名空间:

StreamJsonRpc

程序集:

StreamJsonRpc.dll

包:

streamjsonrpc vD:\a\1\s\dotnet\nue-out\_pacmanada9c\StreamJsonRpc.2.9.85

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

public abstract class PipeMessageHandler : StreamJsonRpc.MessageHandlerBase, StreamJsonRpc.Reflection.IJsonRpcMessageBufferManager

type PipeMessageHandler = class
    inherit MessageHandlerBase
    interface IJsonRpcMessageBufferManager

Public MustInherit Class PipeMessageHandler
Inherits MessageHandlerBase
Implements IJsonRpcMessageBufferManager

继承

Object

MessageHandlerBase

PipeMessageHandler

派生

StreamJsonRpc.HeaderDelimitedMessageHandler

StreamJsonRpc.LengthHeaderMessageHandler

StreamJsonRpc.NewLineDelimitedMessageHandler

实现

IJsonRpcMessageBufferManager

构造函数

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)	释放此实例分配的资源，这些资源对于读取和写入都是常见的。 (继承自 MessageHandlerBase)
DisposeAsync()	释放此实例，并取消任何挂起的读取或写入操作。 (继承自 MessageHandlerBase)
DisposeReader()	释放此实例分配的资源，这些资源用于读取 (不写入) 。
DisposeWriter()	释放此实例分配的资源，这些资源用于写入 (不读取) 。
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)	通知释放保留的缓冲区以反序列化消息的有效负载是安全的，因为所有反序列化尝试都已完成。