types

type Callbacks struct {
	OnConnectionOpen  func(connection Session)
	OnConnectionClose func(connection Session)

	OnStreamOpenCallback  func(stream Stream)
	OnStreamCloseCallback func(stream Stream, error int)
}

type ClientSession interface {
	OpenStream() Stream

	Session
}

type Options interface {
	Get() (bool, string, string, string, string, string, uint64, bool)
}

type Packet struct {
	Streamid   uint64
	Data       []byte
	DataLen    int
	RetAddress *net.UDPAddr
}

type ServerConnection interface {
	// Accept waits for and returns the next connection to the listener.
	Accept() (Stream, error)

	Session
}

type ServerSession interface {
	// Accept waits for and returns the next connection to the listener.
	Accept() (ServerConnection, error)

	Session
}

type Session interface {
	ID() uint64

	OnStreamOpen(uint64)
	OnStreamClose(uint64, int)

	GetStream(uint64) Stream

	StreamPacket(*Packet)

	// Addr returns the listener's network address.
	Addr() net.Addr

	// Close closes the listener.
	// Any blocked Accept operations will be unblocked and return errors.
	Close() error
	IsClosed() bool
}

type Stream interface {
	net.Conn

	ID() uint64

	Sync() bool
	OnOpened()
	OnReceived([]byte, int)
	OnSentBytes(uint64)
	OnAckedSentBytes(uint64)
	OnClosed() error

	IsClosed() bool
}