consumer

Overview ¶

Package consumer contains the Consumer protocol handler. It sets up a client which is handling the data coming through a ReadWriteCloser given from the Connector function.

Example:

var wg sync.WaitGroup

consumer, err := Make(func() (io.ReadWriteCloser, error) {
	return net.Dial("tcp","127.0.0.1:2000")
}, channels, terminate, logger)
if err != nil {
	panic(fmt.Sprintf("Could not create consumer: %v", err.Error()))
}
consumer.Run(&wg)