feat(go)!: rework async I/O

- Remove `Completer` abstraction and just always send async values as "pending" in Go. We may want to revisit this in the future with a better approach (e.g. encoding nested async values concurrently and using a `select` to synchronise at encoding position) - Expose `Close` for stream and future types, although for now the callers have to assert for it. Signed-off-by: Roman Volosatovs <[email protected]>
rvolosatovs · Aug 26, 2024 · d6b2c6d · d6b2c6d
1 parent abaef30
commit d6b2c6d
Show file tree

Hide file tree

Showing 19 changed files with 559 additions and 1,205 deletions.
diff --git a/crates/wit-bindgen-go/src/interface.rs b/crates/wit-bindgen-go/src/interface.rs
diff --git a/examples/go/hello-client/cmd/hello-client-nats/main.go b/examples/go/hello-client/cmd/hello-client-nats/main.go
@@ -7,9 +7,9 @@ import (
 	"log/slog"
 	"os"
 
+	"github.com/nats-io/nats.go"
 	"wrpc.io/examples/go/hello-client/bindings/wrpc_examples/hello/handler"
 	wrpcnats "wrpc.io/go/nats"
-	"github.com/nats-io/nats.go"
 )
 
 func run() (err error) {

diff --git a/examples/go/hello-server/cmd/hello-server-nats/main.go b/examples/go/hello-server/cmd/hello-server-nats/main.go
@@ -9,9 +9,9 @@ import (
 	"os/signal"
 	"syscall"
 
+	"github.com/nats-io/nats.go"
 	server "wrpc.io/examples/go/hello-server/bindings"
 	wrpcnats "wrpc.io/go/nats"
-	"github.com/nats-io/nats.go"
 )
 
 type Handler struct{}

diff --git a/examples/go/resources-server/cmd/resources-server-nats/main.go b/examples/go/resources-server/cmd/resources-server-nats/main.go
@@ -10,12 +10,12 @@ import (
 	"sync"
 	"syscall"
 
+	"github.com/google/uuid"
+	"github.com/nats-io/nats.go"
 	server "wrpc.io/examples/go/resources-server/bindings"
 	"wrpc.io/examples/go/resources-server/bindings/exports/wrpc_examples/resources/resources"
 	wrpc "wrpc.io/go"
 	wrpcnats "wrpc.io/go/nats"
-	"github.com/google/uuid"
-	"github.com/nats-io/nats.go"
 )
 
 type Foo struct {