streaming

Wrapper over the streaming gRPC services of CFX.

Classes:

StreamingService(stub, metadata)

Wraps the streaming gRPC services of CFX.

class ansys.cfx.core.services.streaming.StreamingService(stub, metadata: List[Tuple[str, str]])

Bases: object

Wraps the streaming gRPC services of CFX.

Methods

begin_streaming(request, started_evt, ID, stream_begin_method)	Begin streaming from CFX.
end_streaming(ID, stream_begin_method)	End streaming from CFX.

Methods:

__init__(stub, metadata)	Initialize an instance of the StreamingService class.
begin_streaming(request, started_evt, id, ...)	Begin streaming from CFX.
end_streaming(id, stream_begin_method)	End streaming from CFX.

__init__(stub, metadata: List[Tuple[str, str]])

Initialize an instance of the StreamingService class.

begin_streaming(request, started_evt, id, stream_begin_method) → Generator

Begin streaming from CFX.

end_streaming(id, stream_begin_method) → None

End streaming from CFX.