Update RequestChannel API and first frame handling #151
echistyakovAnnotations
10 errors
|
build:
internal/socket/base_socket_test.go#L53
not enough arguments in call to s.RequestChannel
|
|
build:
internal/socket/abstract_socket_test.go#L104
not enough arguments in call to emptyAbstractRSocket.RequestChannel
|
|
build:
internal/socket/abstract_socket_test.go#L94
not enough arguments in call to s.RequestChannel
|
|
build:
internal/socket/abstract_socket_test.go#L89
cannot use func(publisher flux.Flux) flux.Flux {…} (value of type func(publisher "github.com/rsocket/rsocket-go/rx/flux".Flux) "github.com/rsocket/rsocket-go/rx/flux".Flux) as func(payload.Payload, "github.com/rsocket/rsocket-go/rx/flux".Flux) "github.com/rsocket/rsocket-go/rx/flux".Flux value in struct literal
|
|
build:
examples/word_counter/main.go#L89
not enough arguments in call to client.RequestChannel
|
|
build:
examples/word_counter/main.go#L34
cannot use func(requests flux.Flux) flux.Flux {…} (value of type func(requests "github.com/rsocket/rsocket-go/rx/flux".Flux) "github.com/rsocket/rsocket-go/rx/flux".Flux) as func(initialRequest payload.Payload, requests "github.com/rsocket/rsocket-go/rx/flux".Flux) (responses "github.com/rsocket/rsocket-go/rx/flux".Flux) value in argument to rsocket.RequestChannel
|
|
build:
examples/echo/echo.go#L135
cannot use func(payloads flux.Flux) flux.Flux {…} (value of type func(payloads "github.com/rsocket/rsocket-go/rx/flux".Flux) "github.com/rsocket/rsocket-go/rx/flux".Flux) as func(initialRequest payload.Payload, requests "github.com/rsocket/rsocket-go/rx/flux".Flux) (responses "github.com/rsocket/rsocket-go/rx/flux".Flux) value in argument to rsocket.RequestChannel
|
|
build:
cmd/rsocket-cli/runner.go#L253
not enough arguments in call to c.RequestChannel
|
|
build:
cmd/rsocket-cli/runner.go#L251
not enough arguments in call to c.RequestChannel
|
|
build:
cmd/rsocket-cli/runner.go#L192
cannot use func(messages flux.Flux) flux.Flux {…} (value of type func(messages "github.com/rsocket/rsocket-go/rx/flux".Flux) "github.com/rsocket/rsocket-go/rx/flux".Flux) as func(initialRequest payload.Payload, requests "github.com/rsocket/rsocket-go/rx/flux".Flux) (responses "github.com/rsocket/rsocket-go/rx/flux".Flux) value in argument to rsocket.RequestChannel
|