Merge pull request #1 from rsocket/feature/usechannels

Feature/usechannels

Author: robertroeser

.travis.yml

@@ -9,10 +9,8 @@ env:
 install:
   - curl -L https://github.com/google/protobuf/releases/download/v3.6.1/protoc-3.6.1-linux-x86_64.zip -o /tmp/protoc.zip
   - unzip /tmp/protoc.zip -d "$HOME"/protoc
-  - go get -u golang.org/x/lint/golint
-  - go get -u github.com/golangci/golangci-lint/cmd/golangci-lint
-  - go get -u github.com/rsocket/rsocket-rpc-go/protoc-gen-go
 
 script:
+  - make
   - $HOME/protoc/bin/protoc -I examples/ping-pong/ examples/ping-pong/ping-pong.proto --go_out=plugins=rrpc:./examples/ping-pong
-  - go test -v ./...
+  - make test

client.go

@@ -9,12 +9,14 @@ import (
 	"github.com/rsocket/rsocket-go/rx/mono"
 )
 
+// ClientConn struct
 type ClientConn struct {
 	rSocket       rsocket.RSocket
 	meterRegistry MeterRegistry
 	tracer        Tracer
 }
 
+// InvokeRequestResponse invoke request response
 func (p *ClientConn) InvokeRequestResponse(
 	ctx context.Context,
 	srv string,
@@ -43,6 +45,7 @@ func (p *ClientConn) InvokeRequestResponse(
 	return mono.ToChannel(m, ctx)
 }
 
+// InvokeRequestStream invoke request stream
 func (p *ClientConn) InvokeRequestStream(
 	ctx context.Context,
 	srv string,
@@ -69,6 +72,7 @@ func (p *ClientConn) InvokeRequestStream(
 	return flux.ToChannel(p.rSocket.RequestStream(sent), ctx)
 }
 
+// NewClientConn creates new client
 func NewClientConn(c rsocket.RSocket, m MeterRegistry, t Tracer) *ClientConn {
 	return &ClientConn{
 		rSocket:       c,

examples/ping-pong/ping-pong_test.go

@@ -24,7 +24,7 @@ func TestAllInOne(t *testing.T) {
 
 	m := map[string]string{
 		"tcp": "tcp://127.0.0.1:7878",
-		"websocket": "ws://127.0.0.1:7878",
+		//"websocket": "ws://127.0.0.1:7878",
 	}
 	for k, v := range m {
 		t.Run(k, func(t *testing.T) {

go.mod

@@ -4,15 +4,9 @@ go 1.12
 
 require (
 	github.com/golang/protobuf v1.3.2
-	github.com/hoisie/mustache v0.0.0-20120318181656-6dfe7cd5e765
-	github.com/jjeffcaii/reactor-go v0.0.12
+	github.com/jjeffcaii/reactor-go v0.0.16
 	github.com/opentracing/opentracing-go v1.1.0
 	github.com/pkg/errors v0.8.1
-	github.com/rsocket/rsocket-go v0.0.0-00010101000000-000000000000
-	github.com/stretchr/objx v0.2.0 // indirect
+	github.com/rsocket/rsocket-go v0.3.2
 	github.com/stretchr/testify v1.3.0
 )
-
-replace github.com/rsocket/rsocket-go => ../rsocket-go
-
-replace github.com/panjf2000/ants => ../ants