Struct grpcio::Environment[−][src]

pub struct Environment { /* fields omitted */ }
[−]

An object that used to control concurrency and start gRPC event loop.

Implementations

impl Environment[src][−]

pub fn new(cq_count: usize) -> Environment[src][−]

Initialize gRPC and create a thread pool to poll completion queue. The thread pool size and the number of completion queue is specified by cq_count. Each thread polls one completion queue.

Panics

This method will panic if cq_count is 0.

pub fn completion_queues(&self) -> &[CompletionQueue][src][−]

Get all the created completion queues.

pub fn pick_cq(&self) -> CompletionQueue[src][−]

Pick an arbitrary completion queue.

Trait Implementations

impl Drop for Environment[src][+]

Auto Trait Implementations

impl !RefUnwindSafe for Environment

impl Send for Environment

impl Sync for Environment

impl Unpin for Environment

impl !UnwindSafe for Environment

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src][+]

impl<T> Borrow<T> for T where
    T: ?Sized, [src][+]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src][+]

impl<T> From<T> for T[src][+]

impl<T, U> Into<U> for T where
    U: From<T>, [src][+]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src][+]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src][+]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.