stream

Documentation

Index

• type ConnReaderWriterCloser
  • func NewConnReaderWriterCloser() ConnReaderWriterCloser

Types

type ConnReaderWriterCloser

type ConnReaderWriterCloser interface {
	io.Reader
	io.WriteCloser
	// Enroll new connection for streaming purposes
	Enroll(conn net.Conn)
	// Checks if the component is running
	IsOpen() bool
	// Checks if a new stream is started and the component is reading data from the related connection
	IsReading() bool
	// Wait for a new connection is read for the first time
	Wait()
}

Describe capabilities of a connection reader and buffered reader/writer/closer component

func NewConnReaderWriterCloser

func NewConnReaderWriterCloser() ConnReaderWriterCloser