Versions in this module Expand all Collapse all v1 v1.2.10 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)