Module streams 

Structs

EscapableTonicStream

Wraps a tonic stream which exits once it encounters an unrecoverable HTTP Error. This wrapper does not try to differentiate between transient HTTP Errors unrecoverable HTTP errors. Once an error is encountered, the stream will yield the item with the error, and then end the stream. the stream is ended by returning Poll::Ready(None).

FakeEmptyStream

This stream will always return Pending it should be used when subscribing with an empty topics list

NonBlockingStreamRequest

NonBlockingWebStream

TryFromItem

XmtpTonicStream

A stream which maps the tonic error to ApiClientError, and attaches endpoint metadata

Traits

IntoInner

Functions

send

try_from_stream

Wrap a TryStream<T> such that it converts its ‘item’ to T

Type Aliases

ResponseFuture

XmtpStream

Web and Native compatible network stream of Protobuf types from an XMTP Backend.