docs: def _get_inbound_stream(self, stream_id):
          """
          Get or create the inbound stream with the specified ID.
          """
          if stream_id not in self._inbound_streams:
              self._inbound_streams[stream_id] = InboundStream()
          return self._inbound_streams[stream_id]