pipe

Documentation

Index

• func PlugAny(inp <-chan Any, stop <-chan struct{}) (out <-chan Any, done <-chan struct{})
• type Any

Functions

func PlugAny

func PlugAny(inp <-chan Any, stop <-chan struct{}) (out <-chan Any, done <-chan struct{})

PlugAny returns a channel to receive every `inp` before close and a channel to signal this closing. Upon receipt of a stop signal, output is immediately closed, and for graceful termination any remaining input is drained before done is signalled.

Types

type Any

type Any generic.Type

Any is the generic type flowing thru the pipe network.