@callback close_stream(t(), term(), keyword()) :: :ok | {:error, reason()}

@callback open_stream(t(), message(), [stream_opt]) :: {:ok, term()} | {:error, reason()}
when stream_opt:
       {:timeout, pos_integer()}
       | {:request_context, Backplane.McpProtocol.Transport.RequestContext.t()}
       | {:owner, pid()}
       | {:subscription_id, String.t() | integer()}

@callback send_message(t(), message(), [opt]) :: :ok | {:error, reason()}
when opt:
       {:timeout, pos_integer()}
       | {:request_context, Backplane.McpProtocol.Transport.RequestContext.t()}

@callback shutdown(t()) :: :ok | {:error, reason()}

@callback start_link(keyword()) :: GenServer.on_start()

@callback supported_protocol_versions() :: [String.t()] | :all