jina.peapods.stream.client module

class jina.peapods.stream.client.HTTPClientStreamer(args, iolet)[source]

Bases: jina.peapods.stream.client.ClientStreamer

Streamer used at Client to stream HTTP requests/responses to/from HTTPGateway

Parameters
  • args (Namespace) – args from CLI

  • iolet (Union[ForwardRef, ForwardRef, ForwardRef, ForwardRef]) – One of AsyncZmqlet or Grpclet. Used for sending/receiving data to/from the Flow

class jina.peapods.stream.client.WebsocketClientStreamer(args, iolet)[source]

Bases: jina.peapods.stream.client.ClientStreamer

Streamer used at Client to stream Websocket requests/responses to/from WebsocketGateway

Parameters
  • args (Namespace) – args from CLI

  • iolet (Union[ForwardRef, ForwardRef, ForwardRef, ForwardRef]) – One of AsyncZmqlet or Grpclet. Used for sending/receiving data to/from the Flow