observable

package
v0.0.0-...-0f07e46 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 27, 2020 License: GPL-3.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Iterable

type Iterable <-chan interface{}

type Observable

type Observable struct {
	// contains filtered or unexported fields
}

func NewObservable

func NewObservable(any Iterable) *Observable

func (*Observable) Subscribe

func (o *Observable) Subscribe() (Subscription, error)

func (*Observable) UnSubscribe

func (o *Observable) UnSubscribe(sub Subscription)

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func (*Subscriber) Close

func (s *Subscriber) Close()

func (*Subscriber) Emit

func (s *Subscriber) Emit(item interface{})

func (*Subscriber) Out

func (s *Subscriber) Out() Subscription

type Subscription

type Subscription <-chan interface{}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL