package
0.6.7
Repository: https://github.com/wangjuelong/go-streams.git
Documentation: pkg.go.dev

# Functions

NewChanSink returns a new ChanSink instance.
NewChanSource returns a new ChanSource instance.
NewFileSink returns a new FileSink instance.
NewFileSource returns a new FileSource instance.
NewIgnoreSink returns a new IgnoreSink instance.
NewNetSink returns a new NetSink instance.
NewNetSource returns a new NetSource instance.
NewStdoutSink returns a new StdoutSink instance.

# Constants

TCP connection type.
UDP connection type.

# Structs

ChanSink sends data to the output channel.
ChanSource streams data from the input channel.
A FileSink writes items to a file.
FileSource streams data from the file.
IgnoreSink sends items to /dev/null.
NetSink downstreams input events to a network soket.
NetSource network socket connector.
StdoutSink sends items to stdout.

# Type aliases

ConnType connection type.