main.go

@@ -67,10 +67,8 @@ func (r *ReadableStream) Close() (err error) {
 	defer func() {
 		// We don't want any errors to be thrown if the stream is already closed.
 		recovery := recover()
-		if !strings.Contains(fmt.Sprint(recovery), "Can not close stream after closing or error") {
+		if !strings.Contains(recovery.(string), "Can not close stream after closing or error") {
-			if recovery != nil {
+			err = fmt.Errorf("panic: %v", recovery)
-				err = fmt.Errorf("panic: %v", recovery)
-			}
 		}
 	}()
 
@@ -143,10 +141,8 @@ func (w *WritableStream) Close() (err error) {
 	defer func() {
 		// We don't want any errors to be thrown if the stream is already closed.
 		recovery := recover()
-		if !strings.Contains(fmt.Sprint(recovery), "Can not close stream after closing or error") {
+		if !strings.Contains(recovery.(string), "Can not close stream after closing or error") {
-			if recovery != nil {
+			err = fmt.Errorf("panic: %v", recovery)
-				err = fmt.Errorf("panic: %v", recovery)
-			}
 		}
 	}()
 

tests/main.go

@@ -21,10 +21,6 @@ func main() {
 				return
 			}
 			fmt.Println(string(buffer))
-			err = readStream.Close()
-			if err != nil {
-				fmt.Println(err)
-			}
 		}()
 
 		return nil
@@ -38,10 +34,6 @@ func main() {
 				fmt.Println(err)
 				return
 			}
-			err = writeStream.Close()
-			if err != nil {
-				fmt.Println(err)
-			}
 		}()
 
 		return nil