apache / apache/pulsar-client-reactive

Add documentation to use with other Reactive Stream implementations

Open
#15 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
67
Forks
23
Avg merge
22h
Merged PRs (30d)
2

Description

See https://github.com/apache/pulsar-client-reactive/issues/10#issuecomment-1293755039

> One possible solution to the problem is to use Project Reactor's .as method (`

P as(Function, P> transformer)`) to convert a Flux or Mono to another type.
For example, converting to RxJava3, would be as simple as .as(Flowable::from) or .as(Single::from).
Similar chaining with .as method could be done for Akka Streams and any other Reactive Streams implementation.

We should add doc for this in a `tips` section of the README

Contributor guide

Open the contributing guide

Research direction

Read the README and the referenced comment in issue #10 first. Add a tips section documenting how Project Reactor's .as method can convert Flux or Mono to other Reactive Streams implementations, including the RxJava3 examples given in the issue; the README should clearly explain these usage options.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
documentation
Issue type
Documentation
Difficulty
1/5
Estimated time
Under an hour
Activity status
Stale
Clarity
Clearly specified
Newbie friendliness
50/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.