Documentation ¶
Index ¶
- func AutoStreamMake(auto bool) eventStreamOptionFunc
- func DefaultEventStream(id string) serverOptionFunc
- func DiscoverEventStream(discoverEventStream DiscoverEventStreamFunc) serverOptionFunc
- func RegisterEventStream(id string, eventSourceFactory event.SourceFactoryFunc, ...) serverOptionFunc
- func RegisterStream(id string) eventStreamOptionFunc
- type DiscoverEventStreamFunc
- type EventStream
- type Server
- type Stream
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AutoStreamMake ¶
func AutoStreamMake(auto bool) eventStreamOptionFunc
func DefaultEventStream ¶
func DefaultEventStream(id string) serverOptionFunc
func DiscoverEventStream ¶
func DiscoverEventStream(discoverEventStream DiscoverEventStreamFunc) serverOptionFunc
func RegisterEventStream ¶
func RegisterEventStream(id string, eventSourceFactory event.SourceFactoryFunc, options ...eventStreamOptionFunc) serverOptionFunc
func RegisterStream ¶
func RegisterStream(id string) eventStreamOptionFunc
Types ¶
type DiscoverEventStreamFunc ¶
type EventStream ¶
type Stream ¶
type Stream interface { Subscribe(subscriber Subscriber) func() Broadcast(event event.Event) }
type Subscriber ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.