stream2go

README

stream2go

A dart/javscript like Stream API for Go

Documentation

Index

• type Filter
• type Stream
  • func NewStream() (s Stream)
  • func (s Stream) Close()
  • func (s Stream) First() (f *future2go.Future)
  • func (s Stream) Listen(sr Suscriber) (ss Suscription)
  • func (s Stream) Split(f Filter) (y Stream, n Stream)
  • func (s Stream) Transform(t Transformer) (ts Stream)
  • func (s Stream) Where(f Filter) (fs Stream)
  • func (s Stream) WhereNot(f Filter) (fs Stream)
• type StreamController
  • func New() (sc StreamController)
  • func (sc StreamController) Add(Data interface{})
  • func (sc StreamController) Join(s Stream)
• type Suscriber
• type Suscription
  • func NewSuscription(index int, close chan int, sr Suscriber) (s Suscription)
  • func (s Suscription) Close()
• type Transformer

Types

type Filter

type Filter func(interface{}) bool

type Stream

type Stream struct {
	Closed *future2go.Future
	// contains filtered or unexported fields
}

func NewStream

func NewStream() (s Stream)

func (Stream) Close

func (s Stream) Close()

func (Stream) First

func (s Stream) First() (f *future2go.Future)

func (Stream) Listen

func (s Stream) Listen(sr Suscriber) (ss Suscription)

func (Stream) Split

func (s Stream) Split(f Filter) (y Stream, n Stream)

func (Stream) Transform

func (s Stream) Transform(t Transformer) (ts Stream)

func (Stream) Where

func (s Stream) Where(f Filter) (fs Stream)

func (Stream) WhereNot

func (s Stream) WhereNot(f Filter) (fs Stream)

type StreamController

type StreamController struct {
	Stream
}

func New

func New() (sc StreamController)

func (StreamController) Add

func (sc StreamController) Add(Data interface{})

func (StreamController) Join

func (sc StreamController) Join(s Stream)

type Suscriber

type Suscriber func(interface{})

type Suscription

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

func NewSuscription

func NewSuscription(index int, close chan int, sr Suscriber) (s Suscription)

func (Suscription) Close

func (s Suscription) Close()

type Transformer

type Transformer func(interface{}) interface{}