Skip to content
Go

Update RequestChannel API and first frame handling #150

Sign in to view logs

Update RequestChannel API and first frame handling

Update RequestChannel API and first frame handling #150

Triggered via pull request February 11, 2026 00:07
@echistyakovechistyakov
opened #146
echistyakov:update-request-channel-api
Status Failure
Total duration 49s
Artifacts –

go.yml

on: pull_request
build
45s
build
Fit to window
Zoom out
Zoom in

Annotations

10 errors
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
build: rsocket_test.go#L615
cannot use responder (variable of struct type delayedRSocket) as rsocket.RSocket value in return statement: delayedRSocket does not implement rsocket.RSocket (wrong type for method RequestChannel)
build: rsocket_test.go#L511
not enough arguments in call to cli.RequestChannel
build: rsocket_test.go#L483
not enough arguments in call to cli.RequestChannel
build: rsocket_test.go#L357
cannot use func(inputs flux.Flux) flux.Flux {…} (value of type func(inputs "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 RequestChannel
build: rsocket_example_test.go#L146
not enough arguments in call to cli.RequestChannel
build: rsocket_example_test.go#L88
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