Versions in this module Expand all Collapse all v0 v0.2.0 Feb 18, 2019 Changes in this version + func CheckRoutines(t *testing.T) func() + func FlattenErrs(errs []error) error + func GatherErrs(c chan error) []error + func Stress(ca io.Writer, cb io.Reader, opt Options) error + func StressDuplex(ca io.ReadWriter, cb io.ReadWriter, opt Options) error + func TimeOut(t time.Duration) *time.Timer + type Bridge struct + func NewBridge() *Bridge + func (br *Bridge) Drop(fromID, offset, n int) + func (br *Bridge) GetConn0() net.Conn + func (br *Bridge) GetConn1() net.Conn + func (br *Bridge) Process() + func (br *Bridge) Push(d []byte, fromID int) + func (br *Bridge) Reorder(fromID int) error + func (br *Bridge) Tick() int + type Options struct + MsgCount int + MsgSize int v0.1.0 Jan 23, 2019