udp

Jun 16, 2021

Changes in this version

+ var ErrorNotConnected = errors.New("not connected")

+ type Client interface

+ Close func(code int, reason string)

+ CloseStream func(id string)

+ ID func() string

+ OpenStream func(metadata map[string]string, data map[string]string) (stream *Stream, err error)

+ Send func(msg *network.Message) (rmsg *network.Message, err error)

+ String func() string

+ type Stream struct

+ Closed bool

+ Data map[string]string

+ Exit chan bool

+ Id string

+ Metadata map[string]string

+ func HandleStream(logger *logrus.Logger, stream quic.Stream, ...) (cstream *Stream, err error)

+ func NewStream(metadata map[string]string, data map[string]string, channel *network.Channel) (s *Stream, err error)

+ func NewStreamFromData(data *model.StreamConnectionData, channel *network.Channel) *Stream

+ func (s *Stream) Channel() *network.Channel

+ func (s *Stream) Close()

+ func (s *Stream) Stream() quic.Stream

+ func (s *Stream) String() string

+ type StreamHandler func(Client, *Stream)