MCPcopy Index your code
hub / github.com/ReactiveX/RxJavaAsyncUtil

github.com/ReactiveX/RxJavaAsyncUtil @v0.21.0

Chat with this repo
repository ↗ · DeepWiki ↗ · release v0.21.0 ↗ · + Follow
162 symbols 637 edges 14 files 56 documented · 35%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

RxJava Async Utils

Async utilities for RxJava;

Master Build Status

Communication

Binaries

Binaries and dependency information for Maven, Ivy, Gradle and others can be found at http://search.maven.org.

Example for Maven:

<dependency>
    <groupId>io.reactivex</groupId>
    <artifactId>rxjava-async-util</artifactId>
    <version>x.y.z</version>
</dependency>

and for Ivy:

<dependency org="io.reactivex" name="rxjava-async-util" rev="x.y.z" />

Build

To build:

$ git clone git@github.com:ReactiveX/RxJavaAsyncUtil.git
$ cd RxJavaAsyncUtil/
$ ./gradlew build

Bugs and Feedback

For bugs, questions and discussions please use the Github Issues.

LICENSE

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.

Core symbols most depended-on inside this repo

toAsync
called by 39
src/main/java/rx/util/async/Async.java
fail
called by 19
src/main/java/rx/util/async/operators/LatchedObserver.java
create
called by 16
src/main/java/rx/util/async/operators/LatchedObserver.java
unsubscribe
called by 13
src/main/java/rx/util/async/StoppableObservable.java
onNext
called by 12
src/main/java/rx/util/async/operators/LatchedObserver.java
onError
called by 12
src/main/java/rx/util/async/operators/LatchedObserver.java
onCompleted
called by 12
src/main/java/rx/util/async/operators/LatchedObserver.java
call
called by 9
src/main/java/rx/util/async/operators/Functionals.java

Shape

Method 136
Class 26

Languages

Java100%

Modules by API surface

src/test/java/rx/util/async/AsyncTest.java43 symbols
src/main/java/rx/util/async/operators/LatchedObserver.java23 symbols
src/main/java/rx/util/async/operators/Functionals.java16 symbols
src/main/java/rx/util/async/Async.java14 symbols
src/test/java/rx/util/async/operators/OperatorFromFunctionalsTest.java11 symbols
src/test/java/rx/util/async/operators/OperatorStartFutureTest.java9 symbols
src/main/java/rx/util/async/operators/OperatorFromFunctionals.java9 symbols
src/main/java/rx/util/async/operators/OperatorForEachFuture.java9 symbols
src/main/java/rx/util/async/operators/OperatorDeferFuture.java9 symbols
src/test/java/rx/util/async/operators/OperatorForEachFutureTest.java6 symbols
src/test/java/rx/util/async/operators/OperatorDeferFutureTest.java4 symbols
src/main/java/rx/util/async/StoppableObservable.java4 symbols

For agents

$ claude mcp add RxJavaAsyncUtil \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact