pub struct SubIdGen(/* private fields */);Expand description
Hands out subscription ids, each one larger than the last.
A connector keeps one generator. The user data connector starts at 1000 and the market data connector at 0, so ids of the two kinds do not collide in a log.
§Examples
use brokapi_tbank::util::SubIdGen;
let ids = SubIdGen::new(0);
let (a, b) = (ids.next(), ids.next());
assert_ne!(a, b);
assert_eq!(b.value(), a.value() + 1);Implementations§
Auto Trait Implementations§
impl !Freeze for SubIdGen
impl RefUnwindSafe for SubIdGen
impl Send for SubIdGen
impl Sync for SubIdGen
impl Unpin for SubIdGen
impl UnsafeUnpin for SubIdGen
impl UnwindSafe for SubIdGen
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].