Function TestRecvChanAsyncLeakGoRoutines

test/netchan_test.go:253–279

(t *testing.T)

}

func TestRecvChanAsyncLeakGoRoutines(t *testing.T) {
	s := RunDefaultServer()
	defer s.Shutdown()

	ec := NewEConn(t)
	defer ec.Close()

	// Call this to make sure that we have everything setup connection wise
	ec.Flush()

	base := getStableNumGoroutine(t)

	ch := make(chan int)

	if _, err := ec.BindRecvChan("foo", ch); err != nil {
		t.Fatalf("Failed to bind to a send channel: %v\n", err)
	}

	// Close the receive Channel
	close(ch)

	// The publish will trigger the close and shutdown of the Go routines
	ec.Publish("foo", 22)
	ec.Flush()

	checkNoGoroutineLeak(t, base, "closing channel")
}

func TestRecvChanLeakGoRoutines(t *testing.T) {
	s := RunDefaultServer()