valuestream

Documentation

Index

• func Merge(streams []*oproto.ValueStream) <-chan *oproto.Value
• func MergeBy(streams []*oproto.ValueStream, by string) <-chan []*oproto.ValueStream
• func ToChan(input *oproto.ValueStream) <-chan *oproto.Value
• func ToStream(input <-chan *oproto.Value, output *oproto.ValueStream) *oproto.ValueStream
• type By
  • func (by By) Sort(values []*oproto.ValueStream)

Functions

func Merge

func Merge(streams []*oproto.ValueStream) <-chan *oproto.Value

Merge merges multiple ValueStreams, returning a channel producing sorted Values.

func MergeBy

func MergeBy(streams []*oproto.ValueStream, by string) <-chan []*oproto.ValueStream

func ToChan

func ToChan(input *oproto.ValueStream) <-chan *oproto.Value

FromChan takes a ValueStream and writes all the values individually to a new channel.

func ToStream

func ToStream(input <-chan *oproto.Value, output *oproto.ValueStream) *oproto.ValueStream

ToStream takes a channel of Values and appends each one to the supplied ValueStream.

Types

type By

type By func(p1, p2 *oproto.ValueStream) bool

func (By) Sort

func (by By) Sort(values []*oproto.ValueStream)