Versions in this module Expand all Collapse all v1 v1.1.10 Dec 12, 2023 Changes in this version + type Pipe struct + OnReceiveCompletion func() + OnSendCompletion func() + Receiver Receiver + Sender Sender + func New(req Request) *Pipe + func NewWithFunction(f func(context.Context) (interface{}, error)) (*Pipe, func()) + type Receiver interface + Cancel func() + Receive func() bool + Request func() interface{} + Status func() Status + type Request struct + Canceled bool + Payload interface{} + type Sender interface + Finalize func(v interface{}, err error) + Request func() Request + Status func() Status + Update func(v interface{}) + type Status struct + Canceled bool + Completed bool + Err error + Value interface{}
Go to main page