transport

type Stream interface {
	io.ReadWriteCloser
	// close the write end of the stream, unblock subsequent reads
	CloseWrite() error
}

type StreamDialer interface {
	// Dial connects to the host:port address using the provided context
	Dial(ctx context.Context, address string) (Stream, error)
}

type TCPStreamDialer struct {
	// contains filtered or unexported fields
}