stream

type Stream[SendType, RecvType proto.Message] interface {
	psrpc.ServerStream[SendType, RecvType]

	Ack(context.Context, *internal.Stream) error
	HandleStream(is *internal.Stream) error
	Hijacked() bool
}

type StreamAdapter interface {
	Send(ctx context.Context, msg *internal.Stream) error
	Close(streamID string)
}