feat(go-nats): close streams

Signed-off-by: Roman Volosatovs <[email protected]>

go/nats/client.go

@@ -166,6 +166,13 @@ func (w *paramWriter) Index(path ...uint32) (wrpc.IndexWriter, error) {
 	return nil, errors.New("indexing not supported yet")
 }
 
+func (w *paramWriter) Close() error {
+	if err := w.nc.Publish(w.tx, nil); err != nil {
+		return fmt.Errorf("failed to send shutdown message: %w", err)
+	}
+	return nil
+}
+
 type resultWriter struct {
 	nc *nats.Conn
 	tx string
@@ -197,6 +204,13 @@ func (w *resultWriter) WriteByte(b byte) error {
 	return nil
 }
 
+func (w *resultWriter) Close() error {
+	if err := w.nc.Publish(w.tx, nil); err != nil {
+		return fmt.Errorf("failed to send shutdown message: %w", err)
+	}
+	return nil
+}
+
 func (w *resultWriter) Index(path ...uint32) (wrpc.IndexWriter, error) {
 	return &resultWriter{nc: w.nc, tx: indexPath(w.tx, path...)}, nil
 }