Documentation
¶
Index ¶
- Constants
- func ChanPointer(inp ...*SomeType) chan *SomeType
- func ChanPointerFuncErr(act func() (*SomeType, error)) <-chan *SomeType
- func ChanPointerFuncNok(act func() (*SomeType, bool)) <-chan *SomeType
- func ChanPointerS(inp ...[]*SomeType) chan []*SomeType
- func ChanPointerSFuncErr(act func() ([]*SomeType, error)) <-chan []*SomeType
- func ChanPointerSFuncNok(act func() ([]*SomeType, bool)) <-chan []*SomeType
- func ChanPointerSSlice(inp ...[][]*SomeType) chan []*SomeType
- func ChanPointerSlice(inp ...[]*SomeType) chan *SomeType
- func ChanSomeType(inp ...SomeType) chan SomeType
- func ChanSomeTypeFuncErr(act func() (SomeType, error)) <-chan SomeType
- func ChanSomeTypeFuncNok(act func() (SomeType, bool)) <-chan SomeType
- func ChanSomeTypeS(inp ...[]SomeType) chan []SomeType
- func ChanSomeTypeSFuncErr(act func() ([]SomeType, error)) <-chan []SomeType
- func ChanSomeTypeSFuncNok(act func() ([]SomeType, bool)) <-chan []SomeType
- func ChanSomeTypeSSlice(inp ...[][]SomeType) chan []SomeType
- func ChanSomeTypeSlice(inp ...[]SomeType) chan SomeType
- func DonePointer(inp <-chan *SomeType) chan struct{}
- func DonePointerFunc(inp <-chan *SomeType, act func(a *SomeType)) chan struct{}
- func DonePointerS(inp <-chan []*SomeType) chan struct{}
- func DonePointerSFunc(inp <-chan []*SomeType, act func(a []*SomeType)) chan struct{}
- func DonePointerSSlice(inp <-chan []*SomeType) chan [][]*SomeType
- func DonePointerSlice(inp <-chan *SomeType) chan []*SomeType
- func DoneSomeType(inp <-chan SomeType) chan struct{}
- func DoneSomeTypeFunc(inp <-chan SomeType, act func(a SomeType)) chan struct{}
- func DoneSomeTypeS(inp <-chan []SomeType) chan struct{}
- func DoneSomeTypeSFunc(inp <-chan []SomeType, act func(a []SomeType)) chan struct{}
- func DoneSomeTypeSSlice(inp <-chan []SomeType) chan [][]SomeType
- func DoneSomeTypeSlice(inp <-chan SomeType) chan []SomeType
- func JoinPointer(out chan<- *SomeType, inp ...*SomeType) chan struct{}
- func JoinPointerChan(out chan<- *SomeType, inp <-chan *SomeType) chan struct{}
- func JoinPointerS(out chan<- []*SomeType, inp ...[]*SomeType) chan struct{}
- func JoinPointerSChan(out chan<- []*SomeType, inp <-chan []*SomeType) chan struct{}
- func JoinPointerSSlice(out chan<- []*SomeType, inp ...[][]*SomeType) chan struct{}
- func JoinPointerSlice(out chan<- *SomeType, inp ...[]*SomeType) chan struct{}
- func JoinSomeType(out chan<- SomeType, inp ...SomeType) chan struct{}
- func JoinSomeTypeChan(out chan<- SomeType, inp <-chan SomeType) chan struct{}
- func JoinSomeTypeS(out chan<- []SomeType, inp ...[]SomeType) chan struct{}
- func JoinSomeTypeSChan(out chan<- []SomeType, inp <-chan []SomeType) chan struct{}
- func JoinSomeTypeSSlice(out chan<- []SomeType, inp ...[][]SomeType) chan struct{}
- func JoinSomeTypeSlice(out chan<- SomeType, inp ...[]SomeType) chan struct{}
- func MakePointerChan() chan *SomeType
- func MakePointerSChan() chan []*SomeType
- func MakeSomeTypeChan() chan SomeType
- func MakeSomeTypeSChan() chan []SomeType
- func PipePointerBuffer(inp <-chan *SomeType, cap int) chan *SomeType
- func PipePointerFork(inp <-chan *SomeType) (chan *SomeType, chan *SomeType)
- func PipePointerFunc(inp <-chan *SomeType, act func(a *SomeType) *SomeType) chan *SomeType
- func PipePointerSBuffer(inp <-chan []*SomeType, cap int) chan []*SomeType
- func PipePointerSFork(inp <-chan []*SomeType) (chan []*SomeType, chan []*SomeType)
- func PipePointerSFunc(inp <-chan []*SomeType, act func(a []*SomeType) []*SomeType) chan []*SomeType
- func PipeSomeTypeBuffer(inp <-chan SomeType, cap int) chan SomeType
- func PipeSomeTypeFork(inp <-chan SomeType) (chan SomeType, chan SomeType)
- func PipeSomeTypeFunc(inp <-chan SomeType, act func(a SomeType) SomeType) chan SomeType
- func PipeSomeTypeSBuffer(inp <-chan []SomeType, cap int) chan []SomeType
- func PipeSomeTypeSFork(inp <-chan []SomeType) (chan []SomeType, chan []SomeType)
- func PipeSomeTypeSFunc(inp <-chan []SomeType, act func(a []SomeType) []SomeType) chan []SomeType
- func PointerDaisy(inp <-chan *SomeType, tube PointerTube) (out <-chan *SomeType)
- func PointerDaisyChain(inp <-chan *SomeType, tubes ...PointerTube) (out <-chan *SomeType)
- func PointerSDaisy(inp <-chan []*SomeType, tube PointerSTube) (out <-chan []*SomeType)
- func PointerSDaisyChain(inp <-chan []*SomeType, tubes ...PointerSTube) (out <-chan []*SomeType)
- func SendProxyPointer(out chan<- *SomeType) chan<- *SomeType
- func SendProxyPointerS(out chan<- []*SomeType) chan<- []*SomeType
- func SendProxySomeType(out chan<- SomeType) chan<- SomeType
- func SendProxySomeTypeS(out chan<- []SomeType) chan<- []SomeType
- func SomeTypeDaisy(inp <-chan SomeType, tube SomeTypeTube) (out <-chan SomeType)
- func SomeTypeDaisyChain(inp <-chan SomeType, tubes ...SomeTypeTube) (out <-chan SomeType)
- func SomeTypeSDaisy(inp <-chan []SomeType, tube SomeTypeSTube) (out <-chan []SomeType)
- func SomeTypeSDaisyChain(inp <-chan []SomeType, tubes ...SomeTypeSTube) (out <-chan []SomeType)
- type PointerSTube
- type PointerTube
- type SomeType
- type SomeTypeSTube
- type SomeTypeTube
Constants ¶
const PointerCAP = 10
PointerCAP is the capacity of the buffered proxy channel
const PointerQUE = 16
PointerQUE is the allocated size of the circular queue
const PointerSCAP = 10
PointerSCAP is the capacity of the buffered proxy channel
const PointerSQUE = 16
PointerSQUE is the allocated size of the circular queue
const SomeTypeCAP = 10
SomeTypeCAP is the capacity of the buffered proxy channel
const SomeTypeQUE = 16
SomeTypeQUE is the allocated size of the circular queue
const SomeTypeSCAP = 10
SomeTypeSCAP is the capacity of the buffered proxy channel
const SomeTypeSQUE = 16
SomeTypeSQUE is the allocated size of the circular queue
Variables ¶
This section is empty.
Functions ¶
func ChanPointer ¶
ChanPointer returns a channel to receive all inputs before close.
func ChanPointerFuncErr ¶
ChanPointerFuncErr returns a channel to receive all results of act until err != nil before close.
func ChanPointerFuncNok ¶
ChanPointerFuncNok returns a channel to receive all results of act until nok before close.
func ChanPointerS ¶
ChanPointerS returns a channel to receive all inputs before close.
func ChanPointerSFuncErr ¶
ChanPointerSFuncErr returns a channel to receive all results of act until err != nil before close.
func ChanPointerSFuncNok ¶
ChanPointerSFuncNok returns a channel to receive all results of act until nok before close.
func ChanPointerSSlice ¶
ChanPointerSSlice returns a channel to receive all inputs before close.
func ChanPointerSlice ¶
ChanPointerSlice returns a channel to receive all inputs before close.
func ChanSomeType ¶
ChanSomeType returns a channel to receive all inputs before close.
func ChanSomeTypeFuncErr ¶
ChanSomeTypeFuncErr returns a channel to receive all results of act until err != nil before close.
func ChanSomeTypeFuncNok ¶
ChanSomeTypeFuncNok returns a channel to receive all results of act until nok before close.
func ChanSomeTypeS ¶
ChanSomeTypeS returns a channel to receive all inputs before close.
func ChanSomeTypeSFuncErr ¶
ChanSomeTypeSFuncErr returns a channel to receive all results of act until err != nil before close.
func ChanSomeTypeSFuncNok ¶
ChanSomeTypeSFuncNok returns a channel to receive all results of act until nok before close.
func ChanSomeTypeSSlice ¶
ChanSomeTypeSSlice returns a channel to receive all inputs before close.
func ChanSomeTypeSlice ¶
ChanSomeTypeSlice returns a channel to receive all inputs before close.
func DonePointer ¶
func DonePointer(inp <-chan *SomeType) chan struct{}
DonePointer returns a channel to receive one signal before close after inp has been drained.
func DonePointerFunc ¶
DonePointerFunc returns a channel to receive one signal before close after act has been applied to all inp.
func DonePointerS ¶
func DonePointerS(inp <-chan []*SomeType) chan struct{}
DonePointerS returns a channel to receive one signal before close after inp has been drained.
func DonePointerSFunc ¶
DonePointerSFunc returns a channel to receive one signal before close after act has been applied to all inp.
func DonePointerSSlice ¶
DonePointerSSlice returns a channel which will receive a slice of all the PointerSs received on inp channel before close. Unlike DonePointerS, a full slice is sent once, not just an event.
func DonePointerSlice ¶
DonePointerSlice returns a channel which will receive a slice of all the Pointers received on inp channel before close. Unlike DonePointer, a full slice is sent once, not just an event.
func DoneSomeType ¶
func DoneSomeType(inp <-chan SomeType) chan struct{}
DoneSomeType returns a channel to receive one signal before close after inp has been drained.
func DoneSomeTypeFunc ¶
DoneSomeTypeFunc returns a channel to receive one signal before close after act has been applied to all inp.
func DoneSomeTypeS ¶
func DoneSomeTypeS(inp <-chan []SomeType) chan struct{}
DoneSomeTypeS returns a channel to receive one signal before close after inp has been drained.
func DoneSomeTypeSFunc ¶
DoneSomeTypeSFunc returns a channel to receive one signal before close after act has been applied to all inp.
func DoneSomeTypeSSlice ¶
DoneSomeTypeSSlice returns a channel which will receive a slice of all the SomeTypeSs received on inp channel before close. Unlike DoneSomeTypeS, a full slice is sent once, not just an event.
func DoneSomeTypeSlice ¶
DoneSomeTypeSlice returns a channel which will receive a slice of all the SomeTypes received on inp channel before close. Unlike DoneSomeType, a full slice is sent once, not just an event.
func JoinPointer ¶
JoinPointer sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinPointerChan ¶
JoinPointerChan sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinPointerS ¶
JoinPointerS sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinPointerSChan ¶
JoinPointerSChan sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinPointerSSlice ¶
JoinPointerSSlice sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinPointerSlice ¶
JoinPointerSlice sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinSomeType ¶
JoinSomeType sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinSomeTypeChan ¶
JoinSomeTypeChan sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinSomeTypeS ¶
JoinSomeTypeS sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinSomeTypeSChan ¶
JoinSomeTypeSChan sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinSomeTypeSSlice ¶
JoinSomeTypeSSlice sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func JoinSomeTypeSlice ¶
JoinSomeTypeSlice sends inputs on the given out channel and returns a done channel to receive one signal when inp has been drained
func MakePointerChan ¶
func MakePointerChan() chan *SomeType
MakePointerChan returns a new open channel (simply a 'chan *SomeType' that is).
Note: No 'Pointer-producer' is launched here yet! (as is in all the other functions).
This is useful to easily create corresponding variables such as
var myPointerPipelineStartsHere := MakePointerChan()
// ... lot's of code to design and build Your favourite "myPointerWorkflowPipeline"
// ...
// ... *before* You start pouring data into it, e.g. simply via:
for drop := range water {
myPointerPipelineStartsHere <- drop
}
close(myPointerPipelineStartsHere)
Hint: especially helpful, if Your piping library operates on some hidden (non-exported) type (or on a type imported from elsewhere - and You don't want/need or should(!) have to care.)
Note: as always (except for PipePointerBuffer) the channel is unbuffered.
func MakePointerSChan ¶
func MakePointerSChan() chan []*SomeType
MakePointerSChan returns a new open channel (simply a 'chan []*SomeType' that is).
Note: No 'PointerS-producer' is launched here yet! (as is in all the other functions).
This is useful to easily create corresponding variables such as
var myPointerSPipelineStartsHere := MakePointerSChan()
// ... lot's of code to design and build Your favourite "myPointerSWorkflowPipeline"
// ...
// ... *before* You start pouring data into it, e.g. simply via:
for drop := range water {
myPointerSPipelineStartsHere <- drop
}
close(myPointerSPipelineStartsHere)
Hint: especially helpful, if Your piping library operates on some hidden (non-exported) type (or on a type imported from elsewhere - and You don't want/need or should(!) have to care.)
Note: as always (except for PipePointerSBuffer) the channel is unbuffered.
func MakeSomeTypeChan ¶
func MakeSomeTypeChan() chan SomeType
MakeSomeTypeChan returns a new open channel (simply a 'chan SomeType' that is).
Note: No 'SomeType-producer' is launched here yet! (as is in all the other functions).
This is useful to easily create corresponding variables such as
var mySomeTypePipelineStartsHere := MakeSomeTypeChan()
// ... lot's of code to design and build Your favourite "mySomeTypeWorkflowPipeline"
// ...
// ... *before* You start pouring data into it, e.g. simply via:
for drop := range water {
mySomeTypePipelineStartsHere <- drop
}
close(mySomeTypePipelineStartsHere)
Hint: especially helpful, if Your piping library operates on some hidden (non-exported) type (or on a type imported from elsewhere - and You don't want/need or should(!) have to care.)
Note: as always (except for PipeSomeTypeBuffer) the channel is unbuffered.
func MakeSomeTypeSChan ¶
func MakeSomeTypeSChan() chan []SomeType
MakeSomeTypeSChan returns a new open channel (simply a 'chan []SomeType' that is).
Note: No 'SomeTypeS-producer' is launched here yet! (as is in all the other functions).
This is useful to easily create corresponding variables such as
var mySomeTypeSPipelineStartsHere := MakeSomeTypeSChan()
// ... lot's of code to design and build Your favourite "mySomeTypeSWorkflowPipeline"
// ...
// ... *before* You start pouring data into it, e.g. simply via:
for drop := range water {
mySomeTypeSPipelineStartsHere <- drop
}
close(mySomeTypeSPipelineStartsHere)
Hint: especially helpful, if Your piping library operates on some hidden (non-exported) type (or on a type imported from elsewhere - and You don't want/need or should(!) have to care.)
Note: as always (except for PipeSomeTypeSBuffer) the channel is unbuffered.
func PipePointerBuffer ¶
PipePointerBuffer returns a buffered channel with capacity cap to receive all inp before close.
func PipePointerFork ¶
PipePointerFork returns two channels to receive every result of inp before close.
Note: Yes, it is a VERY simple fanout - but sometimes all You need.
func PipePointerFunc ¶
PipePointerFunc returns a channel to receive every result of act applied to inp before close. Note: it 'could' be PipePointerMap for functional people, but 'map' has a very different meaning in go lang.
func PipePointerSBuffer ¶
PipePointerSBuffer returns a buffered channel with capacity cap to receive all inp before close.
func PipePointerSFork ¶
PipePointerSFork returns two channels to receive every result of inp before close.
Note: Yes, it is a VERY simple fanout - but sometimes all You need.
func PipePointerSFunc ¶
PipePointerSFunc returns a channel to receive every result of act applied to inp before close. Note: it 'could' be PipePointerSMap for functional people, but 'map' has a very different meaning in go lang.
func PipeSomeTypeBuffer ¶
PipeSomeTypeBuffer returns a buffered channel with capacity cap to receive all inp before close.
func PipeSomeTypeFork ¶
PipeSomeTypeFork returns two channels to receive every result of inp before close.
Note: Yes, it is a VERY simple fanout - but sometimes all You need.
func PipeSomeTypeFunc ¶
PipeSomeTypeFunc returns a channel to receive every result of act applied to inp before close. Note: it 'could' be PipeSomeTypeMap for functional people, but 'map' has a very different meaning in go lang.
func PipeSomeTypeSBuffer ¶
PipeSomeTypeSBuffer returns a buffered channel with capacity cap to receive all inp before close.
func PipeSomeTypeSFork ¶
PipeSomeTypeSFork returns two channels to receive every result of inp before close.
Note: Yes, it is a VERY simple fanout - but sometimes all You need.
func PipeSomeTypeSFunc ¶
PipeSomeTypeSFunc returns a channel to receive every result of act applied to inp before close. Note: it 'could' be PipeSomeTypeSMap for functional people, but 'map' has a very different meaning in go lang.
func PointerDaisy ¶
func PointerDaisy(inp <-chan *SomeType, tube PointerTube) (out <-chan *SomeType)
PointerDaisy returns a channel to receive all inp after having passed thru tube.
func PointerDaisyChain ¶
func PointerDaisyChain(inp <-chan *SomeType, tubes ...PointerTube) (out <-chan *SomeType)
PointerDaisyChain returns a channel to receive all inp after having passed thru all tubes.
func PointerSDaisy ¶
func PointerSDaisy(inp <-chan []*SomeType, tube PointerSTube) (out <-chan []*SomeType)
PointerSDaisy returns a channel to receive all inp after having passed thru tube.
func PointerSDaisyChain ¶
func PointerSDaisyChain(inp <-chan []*SomeType, tubes ...PointerSTube) (out <-chan []*SomeType)
PointerSDaisyChain returns a channel to receive all inp after having passed thru all tubes.
func SendProxyPointer ¶
SendProxyPointer returns a channel to serve as a sending proxy to 'out'. Uses a goroutine to receive values from 'out' and store them in an expanding buffer, so that sending to 'out' never blocks.
Note: the expanding buffer is implemented via "container/ring"
func SendProxyPointerS ¶
SendProxyPointerS returns a channel to serve as a sending proxy to 'out'. Uses a goroutine to receive values from 'out' and store them in an expanding buffer, so that sending to 'out' never blocks.
Note: the expanding buffer is implemented via "container/ring"
func SendProxySomeType ¶
SendProxySomeType returns a channel to serve as a sending proxy to 'out'. Uses a goroutine to receive values from 'out' and store them in an expanding buffer, so that sending to 'out' never blocks.
Note: the expanding buffer is implemented via "container/ring"
func SendProxySomeTypeS ¶
SendProxySomeTypeS returns a channel to serve as a sending proxy to 'out'. Uses a goroutine to receive values from 'out' and store them in an expanding buffer, so that sending to 'out' never blocks.
Note: the expanding buffer is implemented via "container/ring"
func SomeTypeDaisy ¶
func SomeTypeDaisy(inp <-chan SomeType, tube SomeTypeTube) (out <-chan SomeType)
SomeTypeDaisy returns a channel to receive all inp after having passed thru tube.
func SomeTypeDaisyChain ¶
func SomeTypeDaisyChain(inp <-chan SomeType, tubes ...SomeTypeTube) (out <-chan SomeType)
SomeTypeDaisyChain returns a channel to receive all inp after having passed thru all tubes.
func SomeTypeSDaisy ¶
func SomeTypeSDaisy(inp <-chan []SomeType, tube SomeTypeSTube) (out <-chan []SomeType)
SomeTypeSDaisy returns a channel to receive all inp after having passed thru tube.
func SomeTypeSDaisyChain ¶
func SomeTypeSDaisyChain(inp <-chan []SomeType, tubes ...SomeTypeSTube) (out <-chan []SomeType)
SomeTypeSDaisyChain returns a channel to receive all inp after having passed thru all tubes.
Types ¶
type PointerSTube ¶
PointerSTube is the signature for a pipe function.
type PointerTube ¶
PointerTube is the signature for a pipe function.
type SomeTypeSTube ¶
SomeTypeSTube is the signature for a pipe function.
type SomeTypeTube ¶
SomeTypeTube is the signature for a pipe function.
Source Files