Trait MakeInstruments 

pub trait MakeInstruments {
    type Service: SendExcService<SubscribeInstruments>;
    type Future: Future<Output = Result<Self::Service, ExchangeError>>;

    // Required methods
    fn poll_ready(
        &mut self,
        cx: &mut Context<'_>,
    ) -> Poll<Result<(), ExchangeError>>;
    fn make_instruments(
        &mut self,
        options: MakeInstrumentsOptions,
    ) -> Self::Future;

    // Provided method
    fn as_make_instruments_service(&mut self) -> AsService<'_, Self>
       where Self: Sized { ... }
}

Make a service to subscribe instruments.

Required Associated Types

type Service: SendExcService<SubscribeInstruments>

Service to subscribe instruments.

type Future: Future<Output = Result<Self::Service, ExchangeError>>

The future of the service.

Required Methods

fn poll_ready( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), ExchangeError>>

Returns Ready when the factory is able to create more service.

fn make_instruments(&mut self, options: MakeInstrumentsOptions) -> Self::Future

Create a new service to subscribe instruments.

Provided Methods

fn as_make_instruments_service(&mut self) -> AsService<'_, Self>

where Self: Sized,

Convert to a Service.

Implementors

impl<M> MakeInstruments for M

where M: MakeService<MakeInstrumentsOptions, SubscribeInstruments, Response = <SubscribeInstruments as Request>::Response, Error = ExchangeError>, M::Service: SendExcService<SubscribeInstruments>, M::MakeError: Into<ExchangeError>,

type Service = <M as MakeService<MakeInstrumentsOptions, SubscribeInstruments>>::Service

type Future = MapErr<<M as MakeService<MakeInstrumentsOptions, SubscribeInstruments>>::Future, fn(<M as MakeService<MakeInstrumentsOptions, SubscribeInstruments>>::MakeError) -> ExchangeError>