.gitattributes

@@ -1,2 +0,0 @@
-tests/index.html -linguist-detectable
-tests/index.html linguist-vendored

README.md

@@ -1,8 +1,7 @@
 # jsStreams
 
-Go library to communicate with the JS Stream API by bridging the JS ReadableStream and WritableStream objects to a Go io.ReaderCloser and io.WriterCloser.
+Go library to communicate with the JS Stream API by bridging the JS ReadableStream object to a Go io.ReaderCloser.
-It also works vice versa, and with pipe readers/writers.
 
 [![Go Report Card](https://goreportcard.com/badge/git.ailur.dev/ailur/jsStreams)](https://goreportcard.com/report/git.ailur.dev/ailur/jsStreams) [![Go Reference](https://pkg.go.dev/badge/git.ailur.dev/ailur/jsStreams.svg)](https://pkg.go.dev/git.ailur.dev/ailur/jsStreams)
 
-The API is pretty self-explanatory, see the Go Reference badge above for the full documentation.
+The API is pretty self-explanatory - it provides a function to create an io.ReaderCloser from a JS ReadableStream object.

main.go

@@ -67,11 +67,9 @@ 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)
 		}
-		}
 	}()
 
 	r.lock.Lock()
@@ -143,11 +141,9 @@ 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)
 		}
-		}
 	}()
 
 	w.lock.Lock()

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