stream

package

v0.2.3 Latest Latest Go to latest Published: Mar 3, 2025 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Bidirectional struct {
	C1 *Endpoint
	C2 *Endpoint
}

Bidirectional is a bidirectional stream.

func NewBidirectional() *Bidirectional

NewBidirectional returns a new Bidirectional stream.

func (s *Bidirectional) Close() error

Close implements io.Closer.

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

Endpoint modelizes one side of a bidirectional stream.

func (e *Endpoint) Close() error

Close implements io.Closer.

func (e *Endpoint) Read(p []byte) (n int, err error)

func (e *Endpoint) Write(p []byte) (n int, err error)