Function TestWeakTee

channels_test.go:152–154

(t *testing.T)

}

func TestWeakTee(t *testing.T) {
	testTee(t, WeakTee)
}

func testDistribute(t *testing.T, dist func(input SimpleOutChannel, outputs ...SimpleInChannel)) {
	a := NewNativeChannel(None)