pipe

Documentation

Index

• type Pipe
  • func New(req Request) *Pipe
  • func NewWithFunction(f func(context.Context) (interface{}, error)) (*Pipe, func())
• type Receiver
• type Request
• type Sender
• type Status

Types

type Pipe

type Pipe struct {
	Sender              Sender
	Receiver            Receiver
	OnReceiveCompletion func()
	OnSendCompletion    func()
}

func New

func New(req Request) *Pipe

func NewWithFunction

func NewWithFunction(f func(context.Context) (interface{}, error)) (*Pipe, func())

type Receiver

type Receiver interface {
	Receive() bool
	Cancel()
	Status() Status
	Request() interface{}
}

type Request

type Request struct {
	Payload  interface{}
	Canceled bool
}

type Sender

type Sender interface {
	Request() Request
	Update(v interface{})
	Finalize(v interface{}, err error)
	Status() Status
}

type Status

type Status struct {
	Canceled  bool
	Completed bool
	Err       error
	Value     interface{}
}