go/r3-netstatus/sockettoevent.go

   1 // (c) Bernhard Tittelbach, 2013
   2
   3 package main
   4
   5 import (
   6     pubsub "github.com/tuxychandru/pubsub"
   7     r3events "svn.spreadspace.org/realraum/go.svn/r3-eventbroker_zmq/r3events"
   8     )
   9
  10 func ParseZMQr3Event(lines [][]byte, ps *pubsub.PubSub) {
  11     evnt, pubsubcat, err := r3events.UnmarshalByteByte2Event(lines)
  12     if err != nil { return }
  13     ps.Pub(evnt, pubsubcat)
  14 }