Versions in this module Expand all Collapse all v1 v1.0.0 Nov 1, 2018 Changes in this version + type ChannelForwarder struct + ChannelOpen bool + Clients map[string]*Client + ClientsLock *sync.Mutex + InChannel chan *DataMessage + NotifyCousure chan struct{} + OutChannel chan *DataMessage + Reader io.Reader + Writer io.Writer + func (c *ChannelForwarder) Close() + func (c *ChannelForwarder) ReadInputData() + func (c *ChannelForwarder) WriteOutputData() + type Client struct + Id string + func NewClient(id string, conn net.Conn, outChannel chan *DataMessage) *Client + func (c *Client) Close() + func (c *Client) IsDead() bool + func (c *Client) NotifyEOF(isDead bool) + func (c *Client) ReadFromClientToChannel() + func (c *Client) ReadyToClose() bool + func (c *Client) SetReadyToClose(readyToClose bool) + func (c *Client) Terminate() + func (c *Client) Write(data []byte) error + type DataMessage struct + ClientId string + CloseClient bool + Data []byte + DeadClient bool + func NewMessage(clientId string, data []byte) *DataMessage