<commit_before># RxJava Reactive Streams

This library provides adapters between RxJava and [Reactive Streams](http://www.reactive-streams.org).
The Reactive Streams standard defines an API and runtime semantics for reactive data streams, that other tools can implement in order to interoperate with other tools.
This library allows RxJava to interoperate with other implementors of the Reactive Streams API.

It provides the following API:

```lang-java
package rx;

import org.reactivestreams.Publisher;

public abstract class RxReactiveStreams {

    public static <T> Publisher<T> toPublisher(Observable<T> observable) {
      // …
    }

    public static <T> Observable<T> toObservable(Publisher<T> publisher) {<commit_msg>Try again for fenced code block.<commit_after># RxJava Reactive Streams

This library provides adapters between RxJava and [Reactive Streams](http://www.reactive-streams.org).
The Reactive Streams standard defines an API and runtime semantics for reactive data streams, that other tools can implement in order to interoperate with other tools.
This library allows RxJava to interoperate with other implementors of the Reactive Streams API.

It provides the following API:

```java
package rx;

import org.reactivestreams.Publisher;

public abstract class RxReactiveStreams {

    public static <T> Publisher<T> toPublisher(Observable<T> observable) {
      // …
    }

    public static <T> Observable<T> toObservable(Publisher<T> publisher) {
{'fraction_non_alphanumeric': 0.06793478260869565, 'fraction_numerical': 0.0, 'mean_word_length': 4.892, 'pattern_counts': {'":': 0, '<': 15, '<?xml version=': 0, '>': 15, 'https://': 0, 'lorem ipsum': 0, 'www.': 2, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1232074', 'n_tokens_mistral': 427, 'n_tokens_neox': 386, 'n_words': 165}