Lines Matching defs:StreamId

38 StreamId = int  variable
225     def _ensure_stream_exists(self, stream: StreamId) -> None:
256     def create_stream(self, stream: StreamId) -> None:
276     def update_seq_num(self, stream: StreamId, seq_num: SeqNum) -> None:
280     def record_state(self, event: EventId, stream: StreamId) -> None:
286         self, state: Dict[StreamId, SeqNum], other: Dict[StreamId, SeqNum]
291     def stream_wait_for_event(self, stream: StreamId, event: EventId) -> None:
307     def all_streams_wait_for_stream(self, stream: StreamId) -> None:
324         self, current_stream: StreamId, seq_num: SeqNum, other_stream: StreamId
346         stream: StreamId,
424     def _handle_event_record(self, event: EventId, stream: StreamId) -> None:
427     def _handle_event_wait(self, event: EventId, stream: StreamId) -> None:
447     def _handle_stream_creation(self, stream: StreamId) -> None:
453     def _handle_stream_synchronization(self, stream: StreamId) -> None: