jina.peapods.runtimes.asyncio.base

class jina.peapods.runtimes.asyncio.base.AsyncZMQRuntime(args)[source]

Bases: jina.peapods.runtimes.zmq.base.ZMQRuntime

Runtime procedure in the async manners.

Base class of AsyncNewLoopRuntime.

run_forever()[source]

Running method to block the main thread.

async async_cancel()[source]

An async method to cancel.

async async_run_forever()[source]

The async method to run until it is stopped.

class jina.peapods.runtimes.asyncio.base.AsyncNewLoopRuntime(args)[source]

Bases: jina.peapods.runtimes.asyncio.base.AsyncZMQRuntime, abc.ABC

The runtime to start a new event loop.

Base class for GRPCRuntime and RESTRuntime.

run_forever()[source]

Running method to block the main thread.

Run the event loop until a Future is done.

setup()[source]

Setup the event loop.

teardown()[source]

Stop and close the event loop.

async async_setup()[source]

The async method to setup.