+// Copyright (C) The Arvados Authors. All rights reserved.
+//
+// SPDX-License-Identifier: Apache-2.0
+
package streamer
import (
n, err := sr.Read(out)
c.Check(n, Equals, 100)
+ c.Check(err, IsNil)
n, err = sr.Read(out)
c.Check(n, Equals, 0)
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)
+}