Stack Overflow
Stack Overflow

Questions tagged [rsocket-js]

JavaScript implementation of the RSocket protocol intended for use in browsers and/or Node.js.

A JavaScript implementation of the RSocket protocol intended for use in browsers and/or Node.js. From rsocket.io:

[RSocket] is an application protocol providing Reactive Streams semantics over an asynchronous, binary boundary.

It enables the following symmetric interaction models via async message passing over a single connection:

    request/response (stream of 1)
    request/stream (finite stream of many)
    fire-and-forget (no response)
    event subscription (infinite stream of many)
    channel (bi-directional streams)
18 questions
4
votes
1 answer

How to do an infinite requestStream() in RSocket-JS? What happens when subscription.request() runs out?

I'm trying to create a situation where the RSocket JS client listens to a Spring Boot server. When the server has some data for the client, it sends it and the client onNext() triggers and starts processing/displaying that data. Simple enough,…
Ansis Spruģevics
  • 161
  • 5
  • 18
4
votes
0 answers

RSocket-JS + RSocketResumableTransport not working

RSocketResumableTransport does not seems to be working. I have below code where i am using RSocketResumableTransport but it never connects to the server(spring-boot version 2.4.0-M1). I am using rsocket-websocket-client": "0.0.19" version. Below is…
shankar
  • 73
  • 6
2
votes
0 answers

rsocket can't run separate tab in my browser

I have a demo app front-end using angular. I'm using Rsocket and resumeable for the community with my server-side (spring-boot). It runs very well when I open a single tab in my browser but when I open a new tab while the current tab still keeps…
Bau Nguyen Van
  • 31
  • 4
2
votes
1 answer

Is it possible to broadcast with RSockets?

My question: I have implemented RSockets on my back-end (java spring boot) and on my front-end (React.js). My front-end and back-end are able to communicate. However, I would like to know if it is possible to broadcast messages to multiple connected…
August Jelemson
  • 962
  • 1
  • 10
  • 29
2
votes
0 answers

Rsocket JS issue when connecting Spring RSocket based backend

I tried to create a client/server sample using Angular, Spring RSocket, Spring Data Mongo Reactive. The complete codes, check here. The backend code: @SpringBootApplication class RSocketServerApplication fun main(args: Array) { …
Hantsy
  • 8,006
  • 7
  • 64
  • 109
2
votes
1 answer

RSocket Js client not getting elements generated from a Spring Boot RSocket Server

Sample project available on Github: https://github.com/codependent/rsocket-rating-service A Spring Boot RSocket server message mapping expects a requestResponse request, returning a simple POJO: @MessageMapping("request-rating") fun…
codependent
  • 23,193
  • 31
  • 166
  • 308
1
vote
0 answers

Rsocket-js client +Spring RsocketServer. when FluxSink<>.create() to send messages. client does not receive message when js client reloads web browser

My Spring boot serves as a rsocket server. spring-boot-starter-rsocket v2.5.2 and spring-boot-starter v 2.5.2 App has a controller like so- @MessageMapping("request.stream") public Flux requestStream(@Payload String userInfo) throws…
user2198890
  • 11
  • 1
1
vote
0 answers

Webflux RSocket Server using RSocketRequestor sending message to Rsocket-js client .Responder not receiving

My requirement is that as and when some event happens on server, it should push updates to client. Want to use RSocket and not SSE. Will responder configured on the rsocket-js client respond to server request? If yes then how should the rsocket-js…
Vani Koratekere
  • 11
  • 2
1
vote
0 answers

Why does subscribing to RSocket connectionStatus() on a connected socket result in two callback calls?

socket.connectionStatus().subscribe((status) => console.log("Connection status changed: ", status)); results in: Connection status changed: Object { kind: "CONNECTED" } Connection status changed: Object { kind: "CONNECTED" } The documentation of…
Hans Wurst
  • 376
  • 1
  • 3
  • 12
1
vote
1 answer

rsocket-js routing fireAndForget to Spring Boot @MessageMapping

As I understand RSocket-JS supports routing messages using encodeCompositeMetadata and encodeRoute, however, I cannot get the server to accept a fireAndForget message. The server constantly logs the following…
Ansis Spruģevics
  • 161
  • 5
  • 18
1
vote
2 answers

How to push notifications from server to client using Spring Boot RSocket (Backend) and Angular (rsocket-js)?

I am planning to use RSocket for my notifications system. I wanted to use Spring Boot RSocket for my backend (Java) while for my frontend, I will be using Angular using rsocket-js. I was able to quickly spin-up a request-stream interaction model…
junbetterway
  • 236
  • 3
  • 13
0
votes
0 answers

I have an issue with my chat app which using spring boot as backend and javaScript as front end, STOMP over webSocket (socketJS)

I try to send a message from user which subscribe on a specific chat using STOMP and save the message to my database but it fail without give me any idication of error to solve it but after many tries I have been found that the message send not back…
Kamel Hanna
  • 1
0
votes
0 answers

Ionic IOS project using SocketJS and Stomp Error : Whoops! Lost connection to 'URL'

I don't know why my Ionic socketjs service can run successfully in a browser but can not build connection when running as a IOS vm in Xcode. Here's my socketjs service code. Can someone please help me with this, Thanks. import { Injectable } from…
Yida Chen
  • 1
0
votes
0 answers

How to connect socket.io to MongoDB server side of react project?

I have done a project with React which uses ExpressJS to create a server-side already one and use MongoDB there. How to implement socket.io in the message component of the client site and server side or how to connect socket.io on the server…
user17342976
0
votes
1 answer

Rsocket-js Unable to set destination route when connection to channel react native client

I am new to Rsocket and reactive Websocket and I develop an application where I need multiple channels, where my clients can subscribe. Until now I tried 2 solutions but unfortunately non of them workd as I expected. I implemented a reactive…
Gergo
  • 230
  • 2
  • 11
1
2