RxRelay

Objects that are both an Observable and an Action1.

License	Apache License Version 2.0
GroupId	com.jakewharton.rxrelay
ArtifactId	rxrelay
Last Version	1.2.0
Release Date	Oct 6, 2016
Type	jar
Description	RxRelay Objects that are both an Observable and an Action1.
Source Code Management	http://github.com/JakeWharton/RxRelay

Download rxrelay

Filename	Size
rxrelay-1.2.0.pom
rxrelay-1.2.0.jar	39 KB
rxrelay-1.2.0-sources.jar	17 KB
rxrelay-1.2.0-javadoc.jar	57 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.jakewharton.rxrelay/rxrelay/ -->
<dependency>
    <groupId>com.jakewharton.rxrelay</groupId>
    <artifactId>rxrelay</artifactId>
    <version>1.2.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.jakewharton.rxrelay/rxrelay/
implementation 'com.jakewharton.rxrelay:rxrelay:1.2.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.jakewharton.rxrelay/rxrelay/
implementation ("com.jakewharton.rxrelay:rxrelay:1.2.0")

Apache Buildr

'com.jakewharton.rxrelay:rxrelay:jar:1.2.0'

Apache Ivy

<dependency org="com.jakewharton.rxrelay" name="rxrelay" rev="1.2.0">
  <artifact name="rxrelay" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.jakewharton.rxrelay', module='rxrelay', version='1.2.0')
)

Scala SBT

libraryDependencies += "com.jakewharton.rxrelay" % "rxrelay" % "1.2.0"

Leiningen

[com.jakewharton.rxrelay/rxrelay "1.2.0"]

Dependencies

compile (1)

Group / Artifact	Type	Version
io.reactivex : rxjava	jar	1.1.3

test (2)

Group / Artifact	Type	Version
junit : junit	jar	4.12
org.mockito : mockito-core	jar	1.10.19

Project Modules

There are no modules declared in this project.

RxRelay

Relays are RxJava types which are both an Observable and a Consumer.

Basically: A Subject except without the ability to call onComplete or onError.

Subjects are useful to bridge the gap between non-Rx APIs. However, they are stateful in a damaging way: when they receive an onComplete or onError they no longer become usable for moving data. This is the observable contract and sometimes it is the desired behavior. Most times it is not.

Relays are simply Subjects without the aforementioned property. They allow you to bridge non-Rx APIs into Rx easily, and without the worry of accidentally triggering a terminal state.

As more of your code moves to reactive, the need for Subjects and Relays should diminish. In the transitional period, or for quickly adapting a non-Rx API, Relays provide the convenience of Subjects without the worry of the statefulness of terminal event behavior.

Usage

• BehaviorRelay

  Relay that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.

  // observer will receive all events.
  BehaviorRelay<Object> relay = BehaviorRelay.createDefault("default");
  relay.subscribe(observer);
  relay.accept("one");
  relay.accept("two");
  relay.accept("three");

  // observer will receive the "one", "two" and "three" events, but not "zero"
  BehaviorRelay<Object> relay = BehaviorRelay.createDefault("default");
  relay.accept("zero");
  relay.accept("one");
  relay.subscribe(observer);
  relay.accept("two");
  relay.accept("three");

• PublishRelay

  Relay that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.

  PublishRelay<Object> relay = PublishRelay.create();
  // observer1 will receive all events
  relay.subscribe(observer1);
  relay.accept("one");
  relay.accept("two");
  // observer2 will only receive "three"
  relay.subscribe(observer2);
  relay.accept("three");

• ReplayRelay

  Relay that buffers all items it observes and replays them to any Observer that subscribes.

  ReplayRelay<Object> relay = ReplayRelay.create();
  relay.accept("one");
  relay.accept("two");
  relay.accept("three");
  // both of the following will get the events from above
  relay.subscribe(observer1);
  relay.subscribe(observer2);

All relays use the Relay base class which also allows custom implementations.

See the Javadoc for more information.

(There is no AsyncRelay since relays have no terminal events to support its behavior.)

Download

Gradle:

implementation 'com.jakewharton.rxrelay3:rxrelay:3.0.0'

Maven:

<dependency>
  <groupId>com.jakewharton.rxrelay3</groupId>
  <artifactId>rxrelay</artifactId>
  <version>3.0.0</version>
</dependency>

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

License

Copyright 2014 Netflix, Inc.
Copyright 2015 Jake Wharton

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.

Versions

Version
1.2.0 Oct 6, 2016
1.1.0 Apr 11, 2016
1.0.0 Dec 29, 2015