Поделиться через


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)

Применяется к