Bump reactor-go to v0.3.5. (#83)

rsocket · Oct 28, 2020 · 250f752 · 250f752
1 parent 0ac1ac3
commit 250f752
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 6 deletions.
diff --git a/examples/echo_bench/echo_bench.go b/examples/echo_bench/echo_bench.go
@@ -62,17 +62,21 @@ func main() {
 		rx.OnNext(func(input payload.Payload) error {
 			//m2, _ := elem.MetadataUTF8()
 			//assert.Equal(t, m1, m2, "metadata doesn't match")
-			wg.Done()
 			return nil
 		}),
 		rx.OnError(func(e error) {
-			wg.Done()
 			errCount.Inc()
+			wg.Done()
+		}),
+		rx.OnComplete(func() {
+			wg.Done()
 		}),
 	)
 	request := payload.New(data, nil)
 	for i := 0; i < n; i++ {
-		client.RequestResponse(request).SubscribeOn(scheduler.Elastic()).SubscribeWith(context.Background(), sub)
+		client.RequestResponse(request).
+			SubscribeOn(scheduler.Elastic()).
+			SubscribeWith(context.Background(), sub)
 	}
 	wg.Wait()
 	cost := time.Since(now)

diff --git a/go.mod b/go.mod
@@ -6,7 +6,7 @@ require (
 	github.com/golang/mock v1.4.3
 	github.com/google/uuid v1.1.2
 	github.com/gorilla/websocket v1.4.2
-	github.com/jjeffcaii/reactor-go v0.3.4
+	github.com/jjeffcaii/reactor-go v0.3.5
 	github.com/pkg/errors v0.9.1
 	github.com/stretchr/testify v1.6.1
 	github.com/urfave/cli/v2 v2.1.1

diff --git a/go.sum b/go.sum
@@ -10,8 +10,8 @@ github.com/google/uuid v1.1.2 h1:EVhdT+1Kseyi1/pUmXKaFxYsDNy9RQYkMWRH68J/W7Y=
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
 github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
-github.com/jjeffcaii/reactor-go v0.3.4 h1:Ksq4rEmW9/rxvyoDBtptjoSyOLUUSNmAw3SdUbeWlDs=
-github.com/jjeffcaii/reactor-go v0.3.4/go.mod h1:w5NNtYKACJocob2sc18oPf1F0/NJBhWITZcfcEoyZOQ=
+github.com/jjeffcaii/reactor-go v0.3.5 h1:JRTfcG8LiTO23VyB3+ftGgzhgsi/ktj9nM1kpYUrZXw=
+github.com/jjeffcaii/reactor-go v0.3.5/go.mod h1:w5NNtYKACJocob2sc18oPf1F0/NJBhWITZcfcEoyZOQ=
 github.com/panjf2000/ants/v2 v2.4.2 h1:kesjjo8JipN3vNNg1XaiXaeSs6xJweBTgenkBtsrHf8=
 github.com/panjf2000/ants/v2 v2.4.2/go.mod h1:f6F0NZVFsGCp5A7QW/Zj/m92atWwOkY0OIhFxRNFr4A=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=