connect

Documentation

Index

• type Connection
  • func New() *Connection
  • func (c *Connection) Close()
  • func (c *Connection) Send(msg interface{}) error
  • func (c *Connection) SetSubscribeFunc(f func() interface{})
  • func (c *Connection) SetUnsubscribeFunc(f func() interface{})
  • func (c *Connection) Stream() <-chan []byte
  • func (c *Connection) Subscribe() error
  • func (c *Connection) Unsubscribe() error

Types

type Connection

type Connection struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Connection ...

func New

func New() *Connection

New is...

func (*Connection) Close

func (c *Connection) Close()

Close is ...

func (*Connection) Send

func (c *Connection) Send(msg interface{}) error

Send is...

func (*Connection) SetSubscribeFunc

func (c *Connection) SetSubscribeFunc(f func() interface{})

SetSubscribeFunc ...

func (*Connection) SetUnsubscribeFunc

func (c *Connection) SetUnsubscribeFunc(f func() interface{})

SetUnsubscribeFunc ...

func (*Connection) Stream

func (c *Connection) Stream() <-chan []byte

Stream ...

func (*Connection) Subscribe

func (c *Connection) Subscribe() error

Subscribe ...

func (*Connection) Unsubscribe

func (c *Connection) Unsubscribe() error

Unsubscribe ...