Trait Subscribe

pub trait Subscribe {
    type Options;
    type Streamable;
    type Error;

    // Required method
    fn subscribe(
        &mut self,
        options: Self::Options,
    ) -> Result<Self::Streamable, Self::Error>;
}

A boxed future stream to shorten method definitions //pub type FutureStream = impl Stream<Item=E>; Subscriber API used by subscribers to service data

Required Associated Types

type Options

type Streamable

type Error

Required Methods

fn subscribe( &mut self, options: Self::Options, ) -> Result<Self::Streamable, Self::Error>

Locate a DIoT service in the distributed database This returns a future that will resolve to the desired service or an error

Implementors