fakeconn

type FakeConn struct {
	// Write an error to this channel to stop the Read consumer
	ReadCh chan ReaderOrErr

	// Consume messages written to this channel. The caller should Ack() to acknowledge receipt.
	WriteCh chan Msg

	Closed bool

	NextWriterError error
}

type Msg struct {
	Callback chan error
}

type ReaderOrErr struct {
	Reader io.Reader
	Err    error
}