Versions in this module Expand all Collapse all v1 v1.0.0 Jul 26, 2023 Changes in this version + type ObServer struct + func NewObServer(enableSafeMode bool, subArgs ...SubArg) (*ObServer, error) + func (t *ObServer) Publish(topic interface{}, enableCo bool, args ...interface{}) (retErr error) + func (t *ObServer) Subscribe(topic interface{}, subKey interface{}, topicFunc TopicFunc, ...) (retErr error) + func (t *ObServer) Unsubscribe(topic interface{}, subKey interface{}) (retErr error) + type SubArg struct + PreArgs []interface{} + SubKey interface{} + Topic interface{} + TopicFunc TopicFunc + type Subject struct + type TopicFunc func(args ...interface{})