Documentation ¶
Index ¶
- type UUID
- type UUIDCollector
- type UUIDCompleter
- type UUIDCompletionHandler
- type UUIDFilter
- type UUIDFuture
- type UUIDStream
- func (s *UUIDStream) AsChan() (c chan UUID, stop *eventual2go.Completer)
- func (s *UUIDStream) First() *UUIDFuture
- func (s *UUIDStream) FirstWhere(f ...UUIDFilter) *UUIDFuture
- func (s *UUIDStream) FirstWhereNot(f ...UUIDFilter) *UUIDFuture
- func (s *UUIDStream) Listen(ss UUIDSubscriber) *eventual2go.Completer
- func (s *UUIDStream) Split(f UUIDFilter) (*UUIDStream, *UUIDStream)
- func (s *UUIDStream) Where(f ...UUIDFilter) *UUIDStream
- func (s *UUIDStream) WhereNot(f ...UUIDFilter) *UUIDStream
- type UUIDStreamController
- type UUIDSubscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type UUIDCollector ¶
type UUIDCollector struct {
*eventual2go.Collector
}
func NewUUIDCollector ¶
func NewUUIDCollector() *UUIDCollector
func (*UUIDCollector) Add ¶
func (c *UUIDCollector) Add(d UUID)
func (*UUIDCollector) AddFuture ¶
func (c *UUIDCollector) AddFuture(f *UUIDFuture)
func (*UUIDCollector) AddStream ¶
func (c *UUIDCollector) AddStream(s *UUIDStream)
func (*UUIDCollector) Get ¶
func (c *UUIDCollector) Get() UUID
func (*UUIDCollector) Preview ¶
func (c *UUIDCollector) Preview() UUID
type UUIDCompleter ¶
type UUIDCompleter struct {
*eventual2go.Completer
}
func NewUUIDCompleter ¶
func NewUUIDCompleter() *UUIDCompleter
func (*UUIDCompleter) Complete ¶
func (c *UUIDCompleter) Complete(d UUID)
func (*UUIDCompleter) Future ¶
func (c *UUIDCompleter) Future() *UUIDFuture
type UUIDCompletionHandler ¶
type UUIDFilter ¶
type UUIDFuture ¶
type UUIDFuture struct {
*eventual2go.Future
}
func (*UUIDFuture) AsChan ¶
func (f *UUIDFuture) AsChan() chan UUID
func (*UUIDFuture) Result ¶
func (f *UUIDFuture) Result() UUID
func (*UUIDFuture) Then ¶
func (f *UUIDFuture) Then(ch UUIDCompletionHandler) *UUIDFuture
type UUIDStream ¶
type UUIDStream struct {
*eventual2go.Stream
}
func (*UUIDStream) AsChan ¶
func (s *UUIDStream) AsChan() (c chan UUID, stop *eventual2go.Completer)
func (*UUIDStream) First ¶
func (s *UUIDStream) First() *UUIDFuture
func (*UUIDStream) FirstWhere ¶
func (s *UUIDStream) FirstWhere(f ...UUIDFilter) *UUIDFuture
func (*UUIDStream) FirstWhereNot ¶
func (s *UUIDStream) FirstWhereNot(f ...UUIDFilter) *UUIDFuture
func (*UUIDStream) Listen ¶
func (s *UUIDStream) Listen(ss UUIDSubscriber) *eventual2go.Completer
func (*UUIDStream) Split ¶
func (s *UUIDStream) Split(f UUIDFilter) (*UUIDStream, *UUIDStream)
func (*UUIDStream) Where ¶
func (s *UUIDStream) Where(f ...UUIDFilter) *UUIDStream
func (*UUIDStream) WhereNot ¶
func (s *UUIDStream) WhereNot(f ...UUIDFilter) *UUIDStream
type UUIDStreamController ¶
type UUIDStreamController struct {
*eventual2go.StreamController
}
func NewUUIDStreamController ¶
func NewUUIDStreamController() *UUIDStreamController
func (*UUIDStreamController) Add ¶
func (sc *UUIDStreamController) Add(d UUID)
func (*UUIDStreamController) Join ¶
func (sc *UUIDStreamController) Join(s *UUIDStream)
func (*UUIDStreamController) JoinFuture ¶
func (sc *UUIDStreamController) JoinFuture(f *UUIDFuture)
func (*UUIDStreamController) Stream ¶
func (sc *UUIDStreamController) Stream() *UUIDStream
type UUIDSubscriber ¶
type UUIDSubscriber func(UUID)
Click to show internal directories.
Click to hide internal directories.