2021-07-04 20:32:00 +03:00
|
|
|
package pipe
|
|
|
|
|
|
2021-07-05 17:12:10 +03:00
|
|
|
type Connector chan StreamItem
|
2021-07-04 20:32:00 +03:00
|
|
|
|
2021-07-05 17:12:10 +03:00
|
|
|
type Source func() chan StreamItem
|
|
|
|
|
type Sink func(chan StreamItem)
|
|
|
|
|
type Pipeline func(chan StreamItem) chan StreamItem
|
