Trait async_nats::jetstream::consumer::FromConsumer

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

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§

source

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

Implementors§

source§

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

source§

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

source§

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

source§

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

source§

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