PipeMessageHandler Класс

Определение

Пространство имен:

StreamJsonRpc

Сборка:

StreamJsonRpc.dll

Пакет:

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

Абстрактный базовый класс для отправки и получения сообщений с использованием PipeReader и PipeWriter.

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)	Уведомляет о безопасном освобождении буферов, удерживаемых для десериализации полезных данных для сообщения, так как все попытки десериализации завершены.