comm

package

v2.3.0 Latest Latest Go to latest Published: Jun 13, 2022 License: MIT, MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Message struct {
	Message  string
	UserName string
}

func (u *Message) IsNil() bool

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

func (m *Message) NKeys() int

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

type Receiver chan *Message

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

type Sender chan gojay.MarshalerJSONObject

Here are defined our communication types

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

type SenderReceiver struct {
	Send    Sender
	Receive Receiver
	Dec     *gojay.StreamDecoder
	Enc     *gojay.StreamEncoder
	Conn    *websocket.Conn
}

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

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

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

func (sc *SenderReceiver) SetReceiver()

func (sc *SenderReceiver) SetSender(nCons int)