Versions in this module Expand all Collapse all v0 v0.5.3 Mar 21, 2021 v0.5.2 Mar 21, 2021 v0.5.1 Mar 21, 2021 Changes in this version + var ErrTerminated = errors.New("terminated") + func Make(connector Connector, channels channels.Consumer, terminate <-chan struct{}, ...) (util.Runner, error) + type Connector func() (io.ReadWriteCloser, error)