robertroeser on master
Routing (#254) This change add… (compare)
robertroeser on master
fix typo (#260) (compare)
robertroeser on master
64-bit Trace Id (#259) Previou… (compare)
Responder
should send to cancel
the remote stream in a channel?
@jakewins I am assuming you are asking about the cancellation of response Publisher
?
Since the response is subscribed to by the Requester
, cancellations flow from the Requester
as a Cancel
frame.Responder
may send Reject
error frame if it does not want to process the request any further.
This section: https://github.com/ReactiveSocket/reactivesocket/blob/master/Protocol.md#request-response explains some interactions.
Requester
sends RequestChannel[..]
, opening two streams, one sending events Responder->Requester
the same way a regular RequestStream
would, and the other sending events Requester->Responder
Responder
side, application code does something like: function handleRequestChannel(in) {
in.subscribe({
onSubscribe:(subscription) {
subscription.cancel()
}
})
}
Cancel
frame as well?
SocketAcceptor
returns Mono.error
, but currently this is not the case.
Hey,
I am trying to use rsocket-websocket-client and rsocket-core from https://github.com/rsocket/rsocket-js
It's a nightmare to configure flow, did anybody had experience with it?
Thanks in adavance
It's not helping me to much
I meant configure https://flow.org/
I getting:
Error: src/scalecube-transport/provider/RSocketProvider.js:2
2: import RSocketWebSocketClient from 'rsocket-websocket-client';
^^^^^^^^^^^^^^^^^^^^^^^^^^ rsocket-websocket-client. Required module not found
Error: src/scalecube-transport/provider/RSocketProvider.js:4
4: import { JsonSerializers, RSocketClient } from 'rsocket-core';
^^^^^^^^^^^^^^ rsocket-core. Required module not found
I tried flow-typed, those packages not there
I also tried to use the .js.flow files in the project, but I wasn't able to config it to work without // $FlowFixMe