socket

type PrimitiveWrapper ¶

type PrimitiveWrapper struct {
	Type      string            `json:"type"`
	Arguments djstate.Primitive `json:"args"`
}

type Subscription ¶

type Subscription struct {
	Document   djlogic.Document
	IRC        djserv.IRCChannel
	Primitives *djbroad.Subscription
	PConn      djproto.Connection
	// contains filtered or unexported fields
}

A Socket.IO connection may subscribe to a Document, and therefore listen to certain events that pertain to that Document.

The Subscription object "lives" via a goroutine that delivers updates to Socket.IO connection. This is terminated upon disconnect.

func NewSubscription(c *deje.DEJEController, url string) (*Subscription, error)

func (s *Subscription) Run(ns *socketio.NameSpace)

func (s *Subscription) SendState(ns *socketio.NameSpace)

func (s *Subscription) Stop()