rsocket-js
rsocket-js copied to clipboard
JavaScript implementation of RSocket
Adds a test suite that exercises various `@rsocket` packages and patterns to ensure compatibility with Browser environments. This is done by compiling the actual test files into a browser-compatible version,...
Adds an adapter package that supports `async/await` and async generators for the various interaction patterns.
State error messages `Flowable: Invalid call to onXxx(): onComplete/onError was already called.'` / `Flowable: Invalid call to onXxx(): onSubscribe has not been called.'` are printed correctly now in `onError` and...
Axios has a standard feature called [interceptors](https://axios-http.com/docs/interceptors). It allow to run custom functions before onSuccess and onError, which is very expressive and allow to make along other things, normalization, validation,...
 always null  ## Expected Behavior ## Actual Behavior ## Steps to Reproduce ```java @Test public void reproCase() { } ``` ## Possible Solution ## Your Environment * RSocket...
Now setupPayload contains data and metadata only, and it should contains keepLive, lifetime, metadataMimeType, dataMimeType attributes. metadataMimeType and dataMimeType is very useful for data encoding/decoding on connection level.
## Motivation Currently, RSocket-Core implicitly brings a `Buffer` polyfill called `LiteBuffer` which is a minimalistic implementation of the Node `Buffer` and has a limited functionality surface to satisfy rsocket-js needs....
Set connection status to ERROR when closed due to protocol error ### Motivation: Addresses #126 ### Modifications: * Amends `DuplexConnection#close` to accept an optional error indicating that the connection is...
Hey there, thanks a lot for this module. We're using this inside a React Native app with the WebSocket client, which apart from a few rough edges has been a...
Hello. With new release 0.0.18 were implemented Composite Metadata: https://github.com/rsocket/rsocket-js/issues/49 Was trying to start using it and got to issue with composite metadata when using rsocket websocket client at browsers:...