http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-rx/vertx-rx-java2-gen: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.reactivex.RxHelper
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.reactivex.RxHelper
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.RxHelper this
         0: .line 17
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.vertx.reactivex.RxHelper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/reactivex/RxHelper;

  public static io.reactivex.Scheduler scheduler(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.Vertx vertx
         0: .line 26
            new io.vertx.reactivex.ContextScheduler
            dup
            aload 0 /* vertx */
            iconst_0
            invokespecial io.vertx.reactivex.ContextScheduler.<init>:(Lio/vertx/core/Vertx;Z)V
            areturn
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  vertx  Lio/vertx/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public static io.reactivex.Scheduler scheduler(io.vertx.core.Context);
    descriptor: (Lio/vertx/core/Context;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.Context context
         0: .line 36
            new io.vertx.reactivex.ContextScheduler
            dup
            aload 0 /* context */
            iconst_0
            invokespecial io.vertx.reactivex.ContextScheduler.<init>:(Lio/vertx/core/Context;Z)V
            areturn
        end local 0 // io.vertx.core.Context context
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  context  Lio/vertx/core/Context;
    MethodParameters:
         Name  Flags
      context  

  public static io.reactivex.Scheduler blockingScheduler(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.Vertx vertx
         0: .line 47
            new io.vertx.reactivex.ContextScheduler
            dup
            aload 0 /* vertx */
            iconst_1
            invokespecial io.vertx.reactivex.ContextScheduler.<init>:(Lio/vertx/core/Vertx;Z)V
            areturn
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  vertx  Lio/vertx/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public static io.reactivex.Scheduler blockingScheduler(io.vertx.core.Vertx, boolean);
    descriptor: (Lio/vertx/core/Vertx;Z)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // boolean ordered
         0: .line 61
            new io.vertx.reactivex.ContextScheduler
            dup
            aload 0 /* vertx */
            iconst_1
            iload 1 /* ordered */
            invokespecial io.vertx.reactivex.ContextScheduler.<init>:(Lio/vertx/core/Vertx;ZZ)V
            areturn
        end local 1 // boolean ordered
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0    vertx  Lio/vertx/core/Vertx;
            0    1     1  ordered  Z
    MethodParameters:
         Name  Flags
      vertx    
      ordered  

  public static io.reactivex.Scheduler blockingScheduler(io.vertx.core.WorkerExecutor);
    descriptor: (Lio/vertx/core/WorkerExecutor;)Lio/reactivex/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.WorkerExecutor executor
         0: .line 71
            new io.vertx.reactivex.ContextScheduler
            dup
            aload 0 /* executor */
            iconst_0
            invokespecial io.vertx.reactivex.ContextScheduler.<init>:(Lio/vertx/core/WorkerExecutor;Z)V
            areturn
        end local 0 // io.vertx.core.WorkerExecutor executor
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    1     0  executor  Lio/vertx/core/WorkerExecutor;
    MethodParameters:
          Name  Flags
      executor  

  public static <T> io.vertx.reactivex.WriteStreamSubscriber<T> toSubscriber(io.vertx.core.streams.WriteStream<T>);
    descriptor: (Lio/vertx/core/streams/WriteStream;)Lio/vertx/reactivex/WriteStreamSubscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.streams.WriteStream stream
         0: .line 84
            aload 0 /* stream */
            invokestatic java.util.function.Function.identity:()Ljava/util/function/Function;
            invokestatic io.vertx.reactivex.RxHelper.toSubscriber:(Lio/vertx/core/streams/WriteStream;Ljava/util/function/Function;)Lio/vertx/reactivex/WriteStreamSubscriber;
            areturn
        end local 0 // io.vertx.core.streams.WriteStream stream
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  stream  Lio/vertx/core/streams/WriteStream<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/streams/WriteStream<TT;>;)Lio/vertx/reactivex/WriteStreamSubscriber<TT;>;
    MethodParameters:
        Name  Flags
      stream  

  public static <R, T> io.vertx.reactivex.WriteStreamSubscriber<R> toSubscriber(io.vertx.core.streams.WriteStream<T>, java.util.function.Function<R, T>);
    descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/util/function/Function;)Lio/vertx/reactivex/WriteStreamSubscriber;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.core.streams.WriteStream stream
        start local 1 // java.util.function.Function mapping
         0: .line 91
            new io.vertx.reactivex.impl.WriteStreamSubscriberImpl
            dup
            aload 0 /* stream */
            aload 1 /* mapping */
            invokespecial io.vertx.reactivex.impl.WriteStreamSubscriberImpl.<init>:(Lio/vertx/core/streams/WriteStream;Ljava/util/function/Function;)V
            areturn
        end local 1 // java.util.function.Function mapping
        end local 0 // io.vertx.core.streams.WriteStream stream
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0   stream  Lio/vertx/core/streams/WriteStream<TT;>;
            0    1     1  mapping  Ljava/util/function/Function<TR;TT;>;
    Signature: <R:Ljava/lang/Object;T:Ljava/lang/Object;>(Lio/vertx/core/streams/WriteStream<TT;>;Ljava/util/function/Function<TR;TT;>;)Lio/vertx/reactivex/WriteStreamSubscriber<TR;>;
    MethodParameters:
         Name  Flags
      stream   
      mapping  

  public static <T> io.vertx.reactivex.WriteStreamObserver<T> toObserver(io.vertx.core.streams.WriteStream<T>);
    descriptor: (Lio/vertx/core/streams/WriteStream;)Lio/vertx/reactivex/WriteStreamObserver;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.streams.WriteStream stream
         0: .line 104
            aload 0 /* stream */
            invokestatic java.util.function.Function.identity:()Ljava/util/function/Function;
            invokestatic io.vertx.reactivex.RxHelper.toObserver:(Lio/vertx/core/streams/WriteStream;Ljava/util/function/Function;)Lio/vertx/reactivex/WriteStreamObserver;
            areturn
        end local 0 // io.vertx.core.streams.WriteStream stream
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  stream  Lio/vertx/core/streams/WriteStream<TT;>;
    Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/streams/WriteStream<TT;>;)Lio/vertx/reactivex/WriteStreamObserver<TT;>;
    MethodParameters:
        Name  Flags
      stream  

  public static <R, T> io.vertx.reactivex.WriteStreamObserver<R> toObserver(io.vertx.core.streams.WriteStream<T>, java.util.function.Function<R, T>);
    descriptor: (Lio/vertx/core/streams/WriteStream;Ljava/util/function/Function;)Lio/vertx/reactivex/WriteStreamObserver;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.core.streams.WriteStream stream
        start local 1 // java.util.function.Function mapping
         0: .line 111
            new io.vertx.reactivex.impl.WriteStreamObserverImpl
            dup
            aload 0 /* stream */
            aload 1 /* mapping */
            invokespecial io.vertx.reactivex.impl.WriteStreamObserverImpl.<init>:(Lio/vertx/core/streams/WriteStream;Ljava/util/function/Function;)V
            areturn
        end local 1 // java.util.function.Function mapping
        end local 0 // io.vertx.core.streams.WriteStream stream
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0   stream  Lio/vertx/core/streams/WriteStream<TT;>;
            0    1     1  mapping  Ljava/util/function/Function<TR;TT;>;
    Signature: <R:Ljava/lang/Object;T:Ljava/lang/Object;>(Lio/vertx/core/streams/WriteStream<TT;>;Ljava/util/function/Function<TR;TT;>;)Lio/vertx/reactivex/WriteStreamObserver<TR;>;
    MethodParameters:
         Name  Flags
      stream   
      mapping  
}
SourceFile: "RxHelper.java"