Function TestDeadChannel

native_channel_test.go:32–58

(t *testing.T)

}

func TestDeadChannel(t *testing.T) {
	ch := NewDeadChannel()

	if ch.Len() != 0 {
		t.Error("dead channel length not 0")
	}
	if ch.Cap() != 0 {
		t.Error("dead channel cap not 0")
	}

	select {
	case <-ch.Out():
		t.Error("read from a dead channel")
	default:
	}

	select {
	case ch.In() <- nil:
		t.Error("wrote to a dead channel")
	default:
	}

	ch.Close()

	ch = NewDeadChannel()
	testChannelConcurrentAccessors(t, "dead channel", ch)
}