From 0315338ef5c5fadd739088684323b82535fc904b Mon Sep 17 00:00:00 2001 From: GrĂ©goire DuchĂȘne Date: Sun, 5 Jun 2022 18:01:39 +0100 Subject: Add Listen, Must, PipeListener, and T --- net_test.go | 50 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 50 insertions(+) create mode 100644 net_test.go (limited to 'net_test.go') diff --git a/net_test.go b/net_test.go new file mode 100644 index 0000000..505579e --- /dev/null +++ b/net_test.go @@ -0,0 +1,50 @@ +package core_test + +import ( + "context" + "syscall" + "testing" + + "go.awhk.org/core" +) + +func TestPipeListener(s *testing.T) { + t := core.T{T: s} + + t.Run("Success", func(t *core.T) { + p := &core.PipeListener{} + + t.Go(func() { + conn, err := p.Accept() + t.AssertErrorIs(nil, err) + t.AssertNotEqual(nil, conn) + }) + + conn, err := p.Dial("", "") + t.AssertErrorIs(nil, err) + t.AssertNotEqual(nil, conn) + }) + + t.Run("WhenClosed", func(t *core.T) { + p := &core.PipeListener{} + p.Close() + + conn, err := p.Accept() + t.AssertErrorIs(syscall.EINVAL, err) + t.AssertEqual(nil, conn) + + conn, err = p.Dial("", "") + t.AssertErrorIs(syscall.ECONNREFUSED, err) + t.AssertEqual(nil, conn) + }) + + t.Run("WhenContextCanceled", func(t *core.T) { + p := &core.PipeListener{} + + ctx, cancel := context.WithCancel(context.Background()) + cancel() + conn, err := p.DialContext(ctx, "", "") + t.AssertErrorIs(context.Canceled, err) + t.AssertEqual(nil, conn) + }) +} -- cgit v1.2.3-70-g09d2