service

Mar 3, 2019

Changes in this version

type Messenger

+ func (m *Messenger) RegisterSome(opCodes []byte, receiver message.Receiver)

Feb 27, 2019

Changes in this version

+ type Device struct

+ type Mesher struct

+ Messenger *Messenger

+ func (msh *Mesher) GetChan() chan proto.Message

+ func (msh *Mesher) Serve()

+ func (msh *Mesher) Stop()

+ type Messenger struct

+ Message chan proto.Message

+ func (m *Messenger) Register(opCode byte, listener message.Receiver)

+ func (m *Messenger) Serve()

+ func (m *Messenger) Stop()

+ type Peer struct

+ type Player struct

+ Message chan proto.Message

+ Messenger *Messenger

+ func (p *Player) Err() error

+ func (p *Player) GetChan() chan proto.Message

+ func (p *Player) Serve()

+ func (p *Player) Stop()

+ func (p *Player) Stream(samples [][2]float64) (n int, ok bool)

+ type Server struct

+ Messenger *Messenger

+ func (srv *Server) GetChan() chan proto.Message

+ func (srv *Server) Serve()

+ func (srv *Server) Stop()

+ type Streamer struct

+ Message chan proto.Message

+ Messenger *Messenger

+ func (s *Streamer) Serve()

+ func (s *Streamer) Stop()