Trait FromConsumer

pub trait FromConsumer {
    // Required method
    fn try_from_consumer_config(config: Config) -> Result<Self, Error>
       where Self: Sized;
}

Trait used to convert generic Stream Config into either Pull or Push config. It validates if given config is a valid target one.

Required Methods

fn try_from_consumer_config(config: Config) -> Result<Self, Error>

where Self: Sized,

Implementors

impl FromConsumer for async_nats::jetstream::consumer::pull::Config

impl FromConsumer for async_nats::jetstream::consumer::pull::OrderedConfig

impl FromConsumer for async_nats::jetstream::consumer::push::Config

impl FromConsumer for async_nats::jetstream::consumer::push::OrderedConfig

impl FromConsumer for async_nats::jetstream::consumer::Config