Short description of the issue:

Currently, the recommended way of extending the library is to use Observable.create() (https://github.com/ReactiveX/RxSwift/blob/master/Documentation/GettingStarted.md#custom-operators). However, this is only possible for the simplest cases.
More complex cases, will require us to understand the implementation details and copy Producer and Sink.

It c

Hi! I am just getting into ReactiveX but am really enjoying it so far. With 3.0 coming out a lot of the old code snippets are out of data and although it's not too difficult to transpose, a lot of the old examples don't cover things like creating Observable from scratch etc.

Are there any plans to work on some training material? If so, I would be happy to send across a list of things that would

We should create a PR to https://github.com/ReactiveX/reactivex.github.io in order to document how RxGo fits in the existing ReactiveX ecosystem and to add RxGo documentation to existing operators.

We need to create our own docker image with git, sphinx-build and gradle to create the documentation and commit it into github.

The default docker image doesn't accept the html tags.

On the Gitter channel -
Peter Majchrak @petoknm Jul 09 09:54
i was missing a template parameter for create

auto ints = rxcpp::observable<>::create<int>( [](rxcpp::subscriber<int> s){ s.on_next(1); s.on_next(2); s.on_completed(); });

please update http://reactive-extensions.github.io/RxCpp/ to reflect that. thanks

Some of the benchmarks don't have the correct scala doc, fixing those.

• https://github.com/monix/monix/blob/master/benchmarks/vnext/src/main/scala/monix/benchmarks/AsyncQueueBenchmark.scala#L41
• https://github.com/monix/monix/blob/master/benchmarks/shared/src/main/scala/monix/benchmarks/CoevalAttemptBenchmark.scala#L38
• https://github.com/monix/monix/blob/master/benchmarks/shared/src/main/

The README shows the extension method "Dialog.toObservable()" which does not exist in 2.2.2 (at least I couldn't find it).
But I could find toMaybe().

Maybe update the doc?

RetryWhen.retryWhenInstanceOf has vararg parameter with generic type, this produces Java warning in code that is using this method. https://docs.oracle.com/javase/tutorial/java/generics/nonReifiableVarargsType.html#vulnerabilities.
It should be enough to add @SafeVarargs to RetryWhen.retryWhenInstanceOf method
Also possible workaround is to use retryIf(e -> e instanceOf X) instead

https://github.com/RxJSInAction/rxjs-in-action/blob/master/examples/4/7/4_7.js

does not correspond to the marble diagram (p.99, Figure 4.8) of 4.3.1 Propagation. Due to the use of the of static operator there is only a single event containing an array of five elements - not five events as depicted in the marble diagram. For that the from static operator has to be used:

``

Somebody in the class had a suggestion to package up the examples in a Jupyter notebook. This sounds like a helpful addition.

To use Fable Reaction with Elmish you need to call the Program.withStream with your reactive query. The query function takes an IAsyncObservable<'msg> and returns a possibibly transformed IAsyncObservable<'msg>.

This doesn't fit to the following code example in Getting Started