X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0f74b22fb1b64f983debb78d7946eb26728fcc52..0f644e242ef37c911ad3dc25aca8135c339de349:/sdk/go/streamer/streamer_test.go diff --git a/sdk/go/streamer/streamer_test.go b/sdk/go/streamer/streamer_test.go index 80aeb26897..f8ddbf5a4c 100644 --- a/sdk/go/streamer/streamer_test.go +++ b/sdk/go/streamer/streamer_test.go @@ -1,3 +1,7 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: Apache-2.0 + package streamer import ( @@ -365,3 +369,13 @@ func (s *StandaloneSuite) TestManyReaders(c *C) { writer.Write([]byte("baz")) writer.Close() } + +func (s *StandaloneSuite) TestMultipleCloseNoPanic(c *C) { + buffer := make([]byte, 100) + tr := AsyncStreamFromSlice(buffer) + sr := tr.MakeStreamReader() + c.Check(sr.Close(), IsNil) + c.Check(sr.Close(), Equals, ErrAlreadyClosed) + c.Check(tr.Close(), IsNil) + c.Check(tr.Close(), Equals, ErrAlreadyClosed) +}