comm

Mar 25, 2019

Changes in this version

+ type Message struct

+ Message string

+ UserName string

+ func (m *Message) MarshalJSONObject(enc *gojay.Encoder)

+ func (m *Message) NKeys() int

+ func (m *Message) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

+ func (u *Message) IsNil() bool

+ type Receiver chan *Message

+ func (s Receiver) UnmarshalStream(dec *gojay.StreamDecoder) error

+ type Sender chan gojay.MarshalerJSONObject

+ func (s Sender) MarshalStream(enc *gojay.StreamEncoder)

+ type SenderReceiver struct

+ Conn *websocket.Conn

+ Dec *gojay.StreamDecoder

+ Enc *gojay.StreamEncoder

+ Receive Receiver

+ Send Sender

+ func (c *SenderReceiver) OnMessage(f func(*Message)) error

+ func (sc *SenderReceiver) Init(sender int) *SenderReceiver

+ func (sc *SenderReceiver) SendMessage(m gojay.MarshalerJSONObject) error

+ func (sc *SenderReceiver) SetReceiver()

+ func (sc *SenderReceiver) SetSender(nCons int)