csync

Documentation

Index

• type Msg
• type Notify
  • func NewNotify() *Notify
  • func (n *Notify) Send(msg interface{}) <-chan interface{}
  • func (n *Notify) Wait() *Msg
  • func (n *Notify) WaitChan() <-chan *Msg

Types

type Msg

type Msg struct {
	Data   interface{}
	Result chan interface{}
}

type Notify

type Notify struct {
	// contains filtered or unexported fields
}

func NewNotify

func NewNotify() *Notify

func (*Notify) Send

func (n *Notify) Send(msg interface{}) <-chan interface{}

func (*Notify) Wait

func (n *Notify) Wait() *Msg

func (*Notify) WaitChan

func (n *Notify) WaitChan() <-chan *Msg