Operator interop between cyclops-react, Reactor and RxJava

[johnmcclean]

ReactiveSeq.of(1,2,3)
                .to(lift(new Observable.Operator<Integer,Integer>(){

                    @Override
                    public Subscriber<? super Integer> call(Subscriber<? super Integer> subscriber) {
                        return subscriber; // operator code
                    }
                            }))
                   .map(i->i+1)
                   .to(observable(o->o.buffer(10)));

And

 ReactiveSeq.of(1,2,3)
                .to(flux(f->f.buffer(publisher))
                .map(i->i*2);

And vice versa

 Flux.just(1,2,3)
     .to(seq(f->f.sliding(1,2))
     .map(i->i*2);

[johnmcclean]

released