Table of Contents Acknowledgment Working With Payload Building communication with RSocket Building Request-Response interaction Implementing Fire and Forget Implementing Request Stream and Request Channel Summary What is next? Acknowledgment This is the second blog post in the series of How to get started with RSocket related blog posts in which I’m going to share the most straightforward tips on running, configuring, and debugging RSocket. In this blog post, I’m going to share some necessary information about existing communication models in RSocket and how to start using them. Read more

Table of Contents Acknowledgment Declaring Core Dependency Constructing RSocket Receiver Declaring Transport Dependency Constructing RSocket Receiver Transport Constructing RSocket Connector Complete Sample Summary What is next? Acknowledgment This is a first blog post in the series of How to get started with RSocket related blog posts in which I’m going to share the most straightforward tips on running, configuring, and debugging RSocket. This series of blog posts do not include the motivation of the RSocket itself which will be delivered in a separate series. Read more

Setup Checkout the project -> git@github.com:CollaborationInEncapsulation/reactive-hardcore.git Open it in the IDEA. Switch to the part-1-... brunch. Checkout the first commit in the history Simple Implementation In this section, you can find all required tests snippets to tests the initial implementation of the Publisher<?>. Step 1. Calls order test Reactive-Streams specification mandates that all method of Subscriber MUST be executed in particular order. Past the following code snippet into the org. Read more