Trait async_nats::jetstream::consumer::FromConsumer

pub trait FromConsumer {
    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][crate::jetstream::consumer::PushConsumerConfig] 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::push::Config

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