RHub module based on RxJava 2.x

Reactive Event Hub connecting Publishers to Subscribers

License

License

Categories

Categories

RxJava Container Microservices Reactive libraries
GroupId

GroupId

io.apptik.rhub
ArtifactId

ArtifactId

rxjava-v2
Last Version

Last Version

0.2.0-alpha1
Release Date

Release Date

Type

Type

jar
Description

Description

RHub module based on RxJava 2.x
Reactive Event Hub connecting Publishers to Subscribers

Download rxjava-v2

How to add to project

<!-- https://jarcasting.com/artifacts/io.apptik.rhub/rxjava-v2/ -->
<dependency>
    <groupId>io.apptik.rhub</groupId>
    <artifactId>rxjava-v2</artifactId>
    <version>0.2.0-alpha1</version>
</dependency>
// https://jarcasting.com/artifacts/io.apptik.rhub/rxjava-v2/
implementation 'io.apptik.rhub:rxjava-v2:0.2.0-alpha1'
// https://jarcasting.com/artifacts/io.apptik.rhub/rxjava-v2/
implementation ("io.apptik.rhub:rxjava-v2:0.2.0-alpha1")
'io.apptik.rhub:rxjava-v2:jar:0.2.0-alpha1'
<dependency org="io.apptik.rhub" name="rxjava-v2" rev="0.2.0-alpha1">
  <artifact name="rxjava-v2" type="jar" />
</dependency>
@Grapes(
@Grab(group='io.apptik.rhub', module='rxjava-v2', version='0.2.0-alpha1')
)
libraryDependencies += "io.apptik.rhub" % "rxjava-v2" % "0.2.0-alpha1"
[io.apptik.rhub/rxjava-v2 "0.2.0-alpha1"]

Dependencies

compile (3)

Group / Artifact Type Version
io.apptik.rhub : rs-core jar 0.2.0-alpha1
io.apptik.rhub : roxy-rxjava2 jar 0.2.0-alpha1
io.reactivex.rxjava2 : rxjava jar 2.0.3

test (5)

Group / Artifact Type Version
junit : junit jar 4.12
org.assertj : assertj-core jar 2.6.0
info.cukes : cucumber-java jar 1.2.5
info.cukes : cucumber-junit jar 1.2.5
info.cukes : cucumber-picocontainer jar 1.2.5

Project Modules

There are no modules declared in this project.

RHub - Reactive Event Hub

JavaDocs

Build Status Android Arsenal

Reactive Hub is a collection of multi-receiver and multi-producer Proxies connecting Publishers and Subscribers so that Subscribers can receive events without knowledge of which Publishers, if any, there are, while maintaining easily identifiable connection between them.

It is ideal for centralizing cross-cutting activities like UI updates, logging, alerting, monitoring, security, etc.

Motivation

  • Simplified combination of Pub/Sub (EventBus) pattern and Reactive Programming
  • Most 'Rx-EventBuses' implementations support only non Rx input/output of events
  • In Standard EventBus the link between producers and event consumers is not that evident thus making the code more difficult to follow, reason and debug

Example

	RxHub rxHub = new DefaultRxJava1Hub();
	rxHub.getPub("src1").subscribe(System.out::println);
	rxHub.addUpstream("src1", Observable.just(1));
	rxHub.addUpstream("src1", Observable.just(5));
	rxHub.getPub("src1").subscribe(System.err::println);

More Examples

Overview

RHub

RHub allows Publish/Subscribe pattern implementation and thus helps decouple components. This can be compared to an EventBus where:

  • publishing events may happen via single post using 'emit()' or by adding a Publisher
  • RHub Proxies take care of connecting publishers and consumers to the Hub
  • The subscriptions and the flow of events is handled by the Reactive Framework (RxJava, Reactor, etc.)

In RHub different set of events are separated into Proxies identified by a Tag(topic).

  • a Hub contains Proxies which can merge inputs from 0-n Publishers and post to 0-n Subscribers
  • a Proxy is identified by a Tag
  • a single event from non-rx code can be emitted on a Proxy

Check also the Gherkin Features

Modules

Download

Find the latest JARs or grab via Maven:

<dependency>
  <groupId>io.apptik.rhub</groupId>
  <artifactId>XXX</artifactId>
  <version>0.2.0-alpha1</version>
</dependency>

or Gradle:

compile 'io.apptik.rhub:XXX:0.2.0-alpha1'

Downloads of the released versions are available in Sonatype's releases repository.

Snapshots of the development versions are available in Sonatype's snapshots repository.

Questions

StackOverflow with tag 'rhub' or 'apptik'

Licence

Copyright (C) 2016 AppTik Project

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

     http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
io.apptik.rhub

AppTik

app toolkit (architecture, development, test, deployment, monitoring)

Versions

Version
0.2.0-alpha1
0.1.0
0.1.0-alpha1