context

type Advice ¶

type Advice interface {
	// contains filtered or unexported methods
}

type Context ¶

type Context[In, Out any] struct {
	Done    <-chan Done
	Monitor chan<- Advice
	In      <-chan In
	Out     chan<- Out
}

func Make[In, Out any](
	done <-chan Done,
	monitor chan<- Advice,
	in <-chan In,
	out chan<- Out,
) *Context[In, Out]

func With[OldIn, OldOut, In, Out any](
	c *Context[OldIn, OldOut], in chan In, out chan Out,
) *Context[In, Out]

func WithIn[OldIn, Out, In any](
	c *Context[OldIn, Out], in chan In,
) *Context[In, Out]

func WithOut[In, OldOut, Out any](
	c *Context[In, OldOut], out chan Out,
) *Context[In, Out]

func (c *Context[In, Out]) Advise(a Advice) bool

func (c *Context[_, _]) Debugf(format string, v ...any) bool

func (c *Context[_, _]) Error(err error) bool

func (c *Context[_, _]) Errorf(format string, v ...any) bool

func (c *Context[_, _]) Fatal(err error) bool

func (c *Context[_, _]) Fatalf(format string, v ...any) bool

func (c *Context[In, Out]) FetchMessage() (In, bool)

func (c *Context[In, Out]) ForwardResult(res Out) bool

func (c *Context[In, Out]) IsDone() bool

type Debug ¶

type Debug struct {
	Message string
	Stack   []byte
}

type Done ¶

type Done struct{}

type Error ¶

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

Error is Advice that reports a recoverable error to the Stream.

type Fatal ¶

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

Fatal is Advice that reports a non-recoverable error to the Stream. The Stream will be stopped when encountering such an error.

type Stop ¶

type Stop struct{}

Stop is Advice that instructs the Stream to completely stop operating. This should only be used in exceptional cases.