jina.peapods.runtimes.gateway.prefetch module

class jina.peapods.runtimes.gateway.prefetch.PrefetchCaller(args, zmqlet)[source]

Bases: object

An async zmq request sender to be used in the Gateway

Parameters
  • args (Namespace) – args from CLI

  • zmqlet (AsyncZmqlet) – zeromq object

async close()[source]

Stop receiving messages

send(request_iterator, *args)[source]

Async call to receive Requests and build them into Messages.

Parameters
  • request_iterator – iterator of requests.

  • args – additional arguments

Yield

message

Return type

AsyncGenerator[None, Message]