Trait TokenStream 

pub trait TokenStream: Send {
    // Required methods
    fn next_token(&mut self) -> BoxFuture<'_, Option<FederationResult<Vec<u8>>>>;
    fn cancel(&mut self) -> BoxFuture<'_, ()>;
}

Streaming token interface

Required Methods

fn next_token(&mut self) -> BoxFuture<'_, Option<FederationResult<Vec<u8>>>>

Get next token (None = stream complete)

fn cancel(&mut self) -> BoxFuture<'_, ()>

Cancel the stream

Implementors