MCPcopy Create free account
hub / github.com/commandoperator/cmdop-sdk / _start_stream

Method _start_stream

python/src/cmdop/_transport.py:291–303  ·  view source on GitHub ↗

Internal: register the stream id + send its REQUEST. Called lazily by :class:`FrameStream` on first iteration so the same stream object can be re-iterated would-be-once semantics.

(self, req: pb.Envelope)

Source from the content-addressed store, hash-verified

Callers 1

__aiter__Method · 0.80

Calls 5

_ensure_startedMethod · 0.95
_alloc_idMethod · 0.95
_writeMethod · 0.95
_StreamPendingClass · 0.85
drainMethod · 0.45

Tested by

no test coverage detected