Versions in this module Expand all Collapse all v0 v0.1.1 Jul 6, 2023 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 StressContext(ctx context.Context, ca connctx.Writer, cb connctx.Reader, opt Options) error + func StressDuplex(ca io.ReadWriter, cb io.ReadWriter, opt Options) error + func StressDuplexContext(ctx context.Context, ca connctx.ReadWriter, cb connctx.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) DropNextNWrites(fromID, n int) + func (br *Bridge) Filter(fromID int, cb func([]byte) bool) + func (br *Bridge) GetConn0() net.Conn + func (br *Bridge) GetConn1() net.Conn + func (br *Bridge) Len(fromID int) int + func (br *Bridge) Process() + func (br *Bridge) Push(packet []byte, fromID int) bool + func (br *Bridge) Reorder(fromID int) error + func (br *Bridge) ReorderNextNWrites(fromID, n int) + func (br *Bridge) SetLossChance(chance int) error + func (br *Bridge) Tick() int + type Options struct + MsgCount int + MsgSize int