struct WorkerServer {
incoming_work: Receiver<Message>,
multi: Multi,
handles: HashMap<usize, (Easy2Handle<Collector>, Sender<Result<Response<Vec<u8>>, Error>>)>,
token: usize,
}Expand description
Manages the cURL Multi. Processes incoming work sent over the
channel, and returns responses.
Fields§
§incoming_work: Receiver<Message>§multi: Multi§handles: HashMap<usize, (Easy2Handle<Collector>, Sender<Result<Response<Vec<u8>>, Error>>)>§token: usizeImplementations§
Source§impl WorkerServer
impl WorkerServer
fn run(incoming_work: Receiver<Message>, multiplex: bool)
fn fail_and_drain(&mut self, e: &Error)
fn worker_loop(&mut self)
Sourcefn enqueue_request(&mut self, message: Message)
fn enqueue_request(&mut self, message: Message)
Adds the request to the Multi, or send an error back through the channel.
Auto Trait Implementations§
impl Freeze for WorkerServer
impl !RefUnwindSafe for WorkerServer
impl !Send for WorkerServer
impl !Sync for WorkerServer
impl Unpin for WorkerServer
impl UnsafeUnpin for WorkerServer
impl !UnwindSafe for WorkerServer
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>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,
§fn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 88 bytes