std

Documentation

Index

• type Out
  • func (sink *Out) Flush(ctx *goconnect.Context) error
  • func (sink *Out) InType() reflect.Type
  • func (sink *Out) Process(input *goconnect.Element, ctx *goconnect.Context)
• type Out2
  • func (sink *Out2) InType() reflect.Type
  • func (sink *Out2) Materialize() func(input *goconnect.Element, context goconnect.PContext)

Types

type Out

type Out struct{}

func (*Out) Flush

func (sink *Out) Flush(ctx *goconnect.Context) error

func (*Out) InType

func (sink *Out) InType() reflect.Type

func (*Out) Process

func (sink *Out) Process(input *goconnect.Element, ctx *goconnect.Context)

type Out2

type Out2 struct{}

func (*Out2) InType

func (sink *Out2) InType() reflect.Type

func (*Out2) Materialize

func (sink *Out2) Materialize() func(input *goconnect.Element, context goconnect.PContext)

this type of implementation doesn't work well because it doesn't have a way of hooking into the termination condition TODO in other words we need a processor that takes a channel input which can be exhausted TODO also the meaning of .TriggerEach and .TriggerEvery is not clear