chore: HTTP runtime yield in pollable

Signed-off-by: Lucas Fontes <[email protected]>

Author: lxfontes

component/net/wasihttp/roundtripper.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"io"
 	"net/http"
+	"runtime"
 	"time"
 
 	"go.bytecodealliance.org/cm"
@@ -116,7 +117,10 @@ func (r *Transport) RoundTrip(incomingRequest *http.Request) (*http.Response, er
 	futureResponse := handleResp.OK()
 
 	// wait until resp is returned
-	futureResponse.Subscribe().Block()
+	futurePollable := futureResponse.Subscribe()
+	for !futurePollable.Ready() {
+		runtime.Gosched()
+	}
 
 	pollableOption := futureResponse.Get()
 	if pollableOption.None() {

component/net/wasihttp/streams.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"io"
 	"net/http"
+	"runtime"
 	"sync"
 
 	"go.bytecodealliance.org/cm"
@@ -87,7 +88,9 @@ func (r *inputStreamReader) parseTrailers() {
 
 func (r *inputStreamReader) Read(p []byte) (n int, err error) {
 	pollable := r.stream.Subscribe()
-	pollable.Block()
+	for !pollable.Ready() {
+		runtime.Gosched()
+	}
 	pollable.ResourceDrop()
 
 	readResult := r.stream.Read(uint64(len(p)))