http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-rx/vertx-rx-java: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class examples.NativeExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.NativeExamples
  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 // examples.NativeExamples this
         0: .line 34
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/NativeExamples;

  public void toObservable(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 37
            aload 1 /* vertx */
            invokeinterface io.vertx.core.Vertx.fileSystem:()Lio/vertx/core/file/FileSystem;
            astore 2 /* fileSystem */
        start local 2 // io.vertx.core.file.FileSystem fileSystem
         1: .line 38
            aload 2 /* fileSystem */
            ldc "/data.txt"
            new io.vertx.core.file.OpenOptions
            dup
            invokespecial io.vertx.core.file.OpenOptions.<init>:()V
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$0(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;Lio/vertx/core/Handler;)Lio/vertx/core/file/FileSystem;
            pop
         2: .line 43
            return
        end local 2 // io.vertx.core.file.FileSystem fileSystem
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lexamples/NativeExamples;
            0    3     1       vertx  Lio/vertx/core/Vertx;
            1    3     2  fileSystem  Lio/vertx/core/file/FileSystem;
    MethodParameters:
       Name  Flags
      vertx  

  private rx.Observable<io.vertx.core.buffer.Buffer> getObservable();
    descriptor: ()Lrx/Observable;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // examples.NativeExamples this
         0: .line 46
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/NativeExamples;
    Signature: ()Lrx/Observable<Lio/vertx/core/buffer/Buffer;>;

  public void toReadStream(io.vertx.rxjava.core.Vertx, io.vertx.core.http.HttpServerResponse);
    descriptor: (Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/http/HttpServerResponse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=6, args_size=3
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
        start local 2 // io.vertx.core.http.HttpServerResponse response
         0: .line 50
            aload 0 /* this */
            invokevirtual examples.NativeExamples.getObservable:()Lrx/Observable;
            astore 3 /* observable */
        start local 3 // rx.Observable observable
         1: .line 51
            aload 3 /* observable */
            invokestatic io.vertx.rx.java.RxHelper.toReadStream:(Lrx/Observable;)Lio/vertx/core/streams/ReadStream;
            astore 4 /* readStream */
        start local 4 // io.vertx.core.streams.ReadStream readStream
         2: .line 52
            aload 4 /* readStream */
            aload 2 /* response */
            invokestatic io.vertx.core.streams.Pump.pump:(Lio/vertx/core/streams/ReadStream;Lio/vertx/core/streams/WriteStream;)Lio/vertx/core/streams/Pump;
            astore 5 /* pump */
        start local 5 // io.vertx.core.streams.Pump pump
         3: .line 53
            aload 5 /* pump */
            invokeinterface io.vertx.core.streams.Pump.start:()Lio/vertx/core/streams/Pump;
            pop
         4: .line 54
            return
        end local 5 // io.vertx.core.streams.Pump pump
        end local 4 // io.vertx.core.streams.ReadStream readStream
        end local 3 // rx.Observable observable
        end local 2 // io.vertx.core.http.HttpServerResponse response
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lexamples/NativeExamples;
            0    5     1       vertx  Lio/vertx/rxjava/core/Vertx;
            0    5     2    response  Lio/vertx/core/http/HttpServerResponse;
            1    5     3  observable  Lrx/Observable<Lio/vertx/core/buffer/Buffer;>;
            2    5     4  readStream  Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
            3    5     5        pump  Lio/vertx/core/streams/Pump;
    MethodParameters:
          Name  Flags
      vertx     
      response  

  public void observableHandler(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 57
            invokestatic io.vertx.rx.java.RxHelper.observableHandler:()Lio/vertx/rx/java/ObservableHandler;
            astore 2 /* observable */
        start local 2 // io.vertx.rx.java.ObservableHandler observable
         1: .line 58
            aload 2 /* observable */
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$2(Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokevirtual io.vertx.rx.java.ObservableHandler.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         2: .line 61
            aload 1 /* vertx */
            ldc 1000
            aload 2 /* observable */
            invokevirtual io.vertx.rx.java.ObservableHandler.toHandler:()Lio/vertx/core/Handler;
            invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
            pop2
         3: .line 62
            return
        end local 2 // io.vertx.rx.java.ObservableHandler observable
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lexamples/NativeExamples;
            0    4     1       vertx  Lio/vertx/core/Vertx;
            1    4     2  observable  Lio/vertx/rx/java/ObservableHandler<Ljava/lang/Long;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void handlerToSubscriber(rx.Observable<java.lang.String>, rx.Single<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.String>>);
    descriptor: (Lrx/Observable;Lrx/Single;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=5, args_size=5
        start local 0 // examples.NativeExamples this
        start local 1 // rx.Observable observable
        start local 2 // rx.Single single
        start local 3 // io.vertx.core.Handler handler1
        start local 4 // io.vertx.core.Handler handler2
         0: .line 70
            aload 1 /* observable */
            aload 3 /* handler1 */
            invokestatic io.vertx.rx.java.RxHelper.toSubscriber:(Lio/vertx/core/Handler;)Lrx/Subscriber;
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         1: .line 73
            aload 2 /* single */
            aload 4 /* handler2 */
            invokestatic io.vertx.rx.java.RxHelper.toSubscriber:(Lio/vertx/core/Handler;)Lrx/Subscriber;
            invokevirtual rx.Single.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         2: .line 74
            return
        end local 4 // io.vertx.core.Handler handler2
        end local 3 // io.vertx.core.Handler handler1
        end local 2 // rx.Single single
        end local 1 // rx.Observable observable
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lexamples/NativeExamples;
            0    3     1  observable  Lrx/Observable<Ljava/lang/String;>;
            0    3     2      single  Lrx/Single<Ljava/lang/String;>;
            0    3     3    handler1  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
            0    3     4    handler2  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;
    Signature: (Lrx/Observable<Ljava/lang/String;>;Lrx/Single<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/String;>;>;)V
    MethodParameters:
            Name  Flags
      observable  
      single      
      handler1    
      handler2    

  public void observableFuture(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 77
            invokestatic io.vertx.rx.java.RxHelper.observableFuture:()Lio/vertx/rx/java/ObservableFuture;
            astore 2 /* observable */
        start local 2 // io.vertx.rx.java.ObservableFuture observable
         1: .line 78
            aload 2 /* observable */
         2: .line 79
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$3(Lio/vertx/core/http/HttpServer;)V (6)
                  (Lio/vertx/core/http/HttpServer;)V
         3: .line 82
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$4(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         4: .line 78
            invokevirtual io.vertx.rx.java.ObservableFuture.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;)Lrx/Subscription;
            pop
         5: .line 86
            aload 1 /* vertx */
            new io.vertx.core.http.HttpServerOptions
            dup
            invokespecial io.vertx.core.http.HttpServerOptions.<init>:()V
         6: .line 87
            sipush 1234
            invokevirtual io.vertx.core.http.HttpServerOptions.setPort:(I)Lio/vertx/core/http/HttpServerOptions;
         7: .line 88
            ldc "localhost"
            invokevirtual io.vertx.core.http.HttpServerOptions.setHost:(Ljava/lang/String;)Lio/vertx/core/http/HttpServerOptions;
         8: .line 86
            invokeinterface io.vertx.core.Vertx.createHttpServer:(Lio/vertx/core/http/HttpServerOptions;)Lio/vertx/core/http/HttpServer;
         9: .line 89
            aload 2 /* observable */
            invokevirtual io.vertx.rx.java.ObservableFuture.toHandler:()Lio/vertx/core/Handler;
            invokeinterface io.vertx.core.http.HttpServer.listen:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpServer;
            pop
        10: .line 90
            return
        end local 2 // io.vertx.rx.java.ObservableFuture observable
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   11     0        this  Lexamples/NativeExamples;
            0   11     1       vertx  Lio/vertx/core/Vertx;
            1   11     2  observable  Lio/vertx/rx/java/ObservableFuture<Lio/vertx/core/http/HttpServer;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void observableToHandler();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // examples.NativeExamples this
         0: .line 93
            new examples.NativeExamples$1
            dup
            aload 0 /* this */
            invokespecial examples.NativeExamples$1.<init>:(Lexamples/NativeExamples;)V
            astore 1 /* observer */
        start local 1 // rx.Observer observer
         1: .line 104
            aload 1 /* observer */
            invokestatic io.vertx.rx.java.RxHelper.toFuture:(Lrx/Observer;)Lio/vertx/core/Handler;
            pop
         2: .line 105
            return
        end local 1 // rx.Observer observer
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lexamples/NativeExamples;
            1    3     1  observer  Lrx/Observer<Lio/vertx/core/http/HttpServer;>;

  public void actionsToHandler();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=1
        start local 0 // examples.NativeExamples this
         0: .line 108
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$5(Lio/vertx/core/http/HttpServer;)V (6)
                  (Lio/vertx/core/http/HttpServer;)V
            astore 1 /* onNext */
        start local 1 // rx.functions.Action1 onNext
         1: .line 109
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$6(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            astore 2 /* onError */
        start local 2 // rx.functions.Action1 onError
         2: .line 110
            invokedynamic call()Lrx/functions/Action0;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  examples/NativeExamples.lambda$7()V (6)
                  ()V
            astore 3 /* onComplete */
        start local 3 // rx.functions.Action0 onComplete
         3: .line 112
            aload 1 /* onNext */
            invokestatic io.vertx.rx.java.RxHelper.toFuture:(Lrx/functions/Action1;)Lio/vertx/core/Handler;
            pop
         4: .line 113
            aload 1 /* onNext */
            aload 2 /* onError */
            invokestatic io.vertx.rx.java.RxHelper.toFuture:(Lrx/functions/Action1;Lrx/functions/Action1;)Lio/vertx/core/Handler;
            pop
         5: .line 114
            aload 1 /* onNext */
            aload 2 /* onError */
            aload 3 /* onComplete */
            invokestatic io.vertx.rx.java.RxHelper.toFuture:(Lrx/functions/Action1;Lrx/functions/Action1;Lrx/functions/Action0;)Lio/vertx/core/Handler;
            pop
         6: .line 115
            return
        end local 3 // rx.functions.Action0 onComplete
        end local 2 // rx.functions.Action1 onError
        end local 1 // rx.functions.Action1 onNext
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lexamples/NativeExamples;
            1    7     1      onNext  Lrx/functions/Action1<Lio/vertx/core/http/HttpServer;>;
            2    7     2     onError  Lrx/functions/Action1<Ljava/lang/Throwable;>;
            3    7     3  onComplete  Lrx/functions/Action0;

  public void scheduler(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=3, args_size=2
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 118
            aload 1 /* vertx */
            invokestatic io.vertx.rx.java.RxHelper.scheduler:(Lio/vertx/core/Vertx;)Lrx/Scheduler;
            astore 2 /* scheduler */
        start local 2 // rx.Scheduler scheduler
         1: .line 119
            ldc 100
            ldc 100
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            aload 2 /* scheduler */
            invokestatic rx.Observable.timer:(JJLjava/util/concurrent/TimeUnit;Lrx/Scheduler;)Lrx/Observable;
            pop
         2: .line 120
            return
        end local 2 // rx.Scheduler scheduler
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lexamples/NativeExamples;
            0    3     1      vertx  Lio/vertx/core/Vertx;
            1    3     2  scheduler  Lrx/Scheduler;
    MethodParameters:
       Name  Flags
      vertx  

  public void blockingScheduler(io.vertx.core.Vertx, rx.Observable<java.lang.Integer>);
    descriptor: (Lio/vertx/core/Vertx;Lrx/Observable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // rx.Observable blockingObservable
         0: .line 123
            aload 1 /* vertx */
            invokestatic io.vertx.rx.java.RxHelper.blockingScheduler:(Lio/vertx/core/Vertx;)Lrx/Scheduler;
            astore 3 /* scheduler */
        start local 3 // rx.Scheduler scheduler
         1: .line 124
            aload 2 /* blockingObservable */
            aload 3 /* scheduler */
            invokevirtual rx.Observable.observeOn:(Lrx/Scheduler;)Lrx/Observable;
            pop
         2: .line 125
            return
        end local 3 // rx.Scheduler scheduler
        end local 2 // rx.Observable blockingObservable
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    3     0                this  Lexamples/NativeExamples;
            0    3     1               vertx  Lio/vertx/core/Vertx;
            0    3     2  blockingObservable  Lrx/Observable<Ljava/lang/Integer;>;
            1    3     3           scheduler  Lrx/Scheduler;
    Signature: (Lio/vertx/core/Vertx;Lrx/Observable<Ljava/lang/Integer;>;)V
    MethodParameters:
                    Name  Flags
      vertx               
      blockingObservable  

  public void schedulerHook(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=3, args_size=2
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 128
            aload 1 /* vertx */
            invokestatic io.vertx.rx.java.RxHelper.schedulerHook:(Lio/vertx/core/Vertx;)Lrx/plugins/RxJavaSchedulersHook;
            astore 2 /* hook */
        start local 2 // rx.plugins.RxJavaSchedulersHook hook
         1: .line 129
            aload 2 /* hook */
            invokedynamic call(Lrx/plugins/RxJavaSchedulersHook;)Lrx/functions/Func1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  examples/NativeExamples.lambda$8(Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler; (6)
                  (Lrx/Scheduler;)Lrx/Scheduler;
            invokestatic rx.plugins.RxJavaHooks.setOnIOScheduler:(Lrx/functions/Func1;)V
         2: .line 130
            aload 2 /* hook */
            invokedynamic call(Lrx/plugins/RxJavaSchedulersHook;)Lrx/functions/Func1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  examples/NativeExamples.lambda$9(Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler; (6)
                  (Lrx/Scheduler;)Lrx/Scheduler;
            invokestatic rx.plugins.RxJavaHooks.setOnNewThreadScheduler:(Lrx/functions/Func1;)V
         3: .line 131
            aload 2 /* hook */
            invokedynamic call(Lrx/plugins/RxJavaSchedulersHook;)Lrx/functions/Func1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  examples/NativeExamples.lambda$10(Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler; (6)
                  (Lrx/Scheduler;)Lrx/Scheduler;
            invokestatic rx.plugins.RxJavaHooks.setOnComputationScheduler:(Lrx/functions/Func1;)V
         4: .line 132
            return
        end local 2 // rx.plugins.RxJavaSchedulersHook hook
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lexamples/NativeExamples;
            0    5     1  vertx  Lio/vertx/core/Vertx;
            1    5     2   hook  Lrx/plugins/RxJavaSchedulersHook;
    MethodParameters:
       Name  Flags
      vertx  

  public void unmarshaller(io.vertx.core.file.FileSystem);
    descriptor: (Lio/vertx/core/file/FileSystem;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.NativeExamples this
        start local 1 // io.vertx.core.file.FileSystem fileSystem
         0: .line 138
            aload 1 /* fileSystem */
            ldc "/data.txt"
            new io.vertx.core.file.OpenOptions
            dup
            invokespecial io.vertx.core.file.OpenOptions.<init>:()V
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$11(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;Lio/vertx/core/Handler;)Lio/vertx/core/file/FileSystem;
            pop
         1: .line 147
            return
        end local 1 // io.vertx.core.file.FileSystem fileSystem
        end local 0 // examples.NativeExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lexamples/NativeExamples;
            0    2     1  fileSystem  Lio/vertx/core/file/FileSystem;
    MethodParameters:
            Name  Flags
      fileSystem  

  private static void lambda$0(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult result
         0: .line 39
            aload 0 /* result */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.core.file.AsyncFile
            astore 1 /* file */
        start local 1 // io.vertx.core.file.AsyncFile file
         1: .line 40
            aload 1 /* file */
            invokestatic io.vertx.rx.java.RxHelper.toObservable:(Lio/vertx/core/streams/ReadStream;)Lrx/Observable;
            astore 2 /* observable */
        start local 2 // rx.Observable observable
         2: .line 41
            aload 2 /* observable */
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$1(Lio/vertx/core/buffer/Buffer;)V (6)
                  (Lio/vertx/core/buffer/Buffer;)V
            invokevirtual rx.Observable.forEach:(Lrx/functions/Action1;)V
        end local 2 // rx.Observable observable
        end local 1 // io.vertx.core.file.AsyncFile file
         3: .line 42
            return
        end local 0 // io.vertx.core.AsyncResult result
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0      result  Lio/vertx/core/AsyncResult<Lio/vertx/core/file/AsyncFile;>;
            1    3     1        file  Lio/vertx/core/file/AsyncFile;
            2    3     2  observable  Lrx/Observable<Lio/vertx/core/buffer/Buffer;>;

  private static void lambda$2(java.lang.Long);
    descriptor: (Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Long id
         0: .line 60
            return
        end local 0 // java.lang.Long id
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    id  Ljava/lang/Long;

  private static void lambda$3(io.vertx.core.http.HttpServer);
    descriptor: (Lio/vertx/core/http/HttpServer;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.http.HttpServer server
         0: .line 81
            return
        end local 0 // io.vertx.core.http.HttpServer server
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  server  Lio/vertx/core/http/HttpServer;

  private static void lambda$4(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Throwable failure
         0: .line 84
            return
        end local 0 // java.lang.Throwable failure
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  failure  Ljava/lang/Throwable;

  private static void lambda$5(io.vertx.core.http.HttpServer);
    descriptor: (Lio/vertx/core/http/HttpServer;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.http.HttpServer httpServer
         0: .line 108
            return
        end local 0 // io.vertx.core.http.HttpServer httpServer
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  httpServer  Lio/vertx/core/http/HttpServer;

  private static void lambda$6(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Throwable httpServer
         0: .line 109
            return
        end local 0 // java.lang.Throwable httpServer
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  httpServer  Ljava/lang/Throwable;

  private static void lambda$7();
    descriptor: ()V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=0, args_size=0
         0: .line 110
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static rx.Scheduler lambda$8(rx.plugins.RxJavaSchedulersHook, rx.Scheduler);
    descriptor: (Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // rx.Scheduler f
         0: .line 129
            aload 0
            invokevirtual rx.plugins.RxJavaSchedulersHook.getIOScheduler:()Lrx/Scheduler;
            areturn
        end local 1 // rx.Scheduler f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     f  Lrx/Scheduler;

  private static rx.Scheduler lambda$9(rx.plugins.RxJavaSchedulersHook, rx.Scheduler);
    descriptor: (Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // rx.Scheduler f
         0: .line 130
            aload 0
            invokevirtual rx.plugins.RxJavaSchedulersHook.getNewThreadScheduler:()Lrx/Scheduler;
            areturn
        end local 1 // rx.Scheduler f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     f  Lrx/Scheduler;

  private static rx.Scheduler lambda$10(rx.plugins.RxJavaSchedulersHook, rx.Scheduler);
    descriptor: (Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // rx.Scheduler f
         0: .line 131
            aload 0
            invokevirtual rx.plugins.RxJavaSchedulersHook.getComputationScheduler:()Lrx/Scheduler;
            areturn
        end local 1 // rx.Scheduler f
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     f  Lrx/Scheduler;

  private static void lambda$11(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult result
         0: .line 139
            aload 0 /* result */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.core.file.AsyncFile
            astore 1 /* file */
        start local 1 // io.vertx.core.file.AsyncFile file
         1: .line 140
            aload 1 /* file */
            invokestatic io.vertx.rx.java.RxHelper.toObservable:(Lio/vertx/core/streams/ReadStream;)Lrx/Observable;
            astore 2 /* observable */
        start local 2 // rx.Observable observable
         2: .line 141
            aload 2 /* observable */
            ldc Lexamples/NativeExamples$MyPojo;
            invokestatic io.vertx.rx.java.RxHelper.unmarshaller:(Ljava/lang/Class;)Lrx/Observable$Operator;
            invokevirtual rx.Observable.lift:(Lrx/Observable$Operator;)Lrx/Observable;
         3: .line 142
            invokedynamic call()Lrx/functions/Action1;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/NativeExamples.lambda$12(Lexamples/NativeExamples$MyPojo;)V (6)
                  (Lexamples/NativeExamples$MyPojo;)V
         4: .line 141
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
        end local 2 // rx.Observable observable
        end local 1 // io.vertx.core.file.AsyncFile file
         5: .line 146
            return
        end local 0 // io.vertx.core.AsyncResult result
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0      result  Lio/vertx/core/AsyncResult<Lio/vertx/core/file/AsyncFile;>;
            1    5     1        file  Lio/vertx/core/file/AsyncFile;
            2    5     2  observable  Lrx/Observable<Lio/vertx/core/buffer/Buffer;>;

  private static void lambda$1(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.buffer.Buffer data
         0: .line 41
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Read data: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* data */
            ldc "UTF-8"
            invokeinterface io.vertx.core.buffer.Buffer.toString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // io.vertx.core.buffer.Buffer data
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  data  Lio/vertx/core/buffer/Buffer;

  private static void lambda$12(examples.NativeExamples$MyPojo);
    descriptor: (Lexamples/NativeExamples$MyPojo;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // examples.NativeExamples$MyPojo mypojo
         0: .line 144
            return
        end local 0 // examples.NativeExamples$MyPojo mypojo
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  mypojo  Lexamples/NativeExamples$MyPojo;
}
SourceFile: "NativeExamples.java"
NestMembers:
  examples.NativeExamples$1  examples.NativeExamples$MyPojo
InnerClasses:
  examples.NativeExamples$1
  private MyPojo = examples.NativeExamples$MyPojo of examples.NativeExamples
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract Operator = rx.Observable$Operator of rx.Observable
    RuntimeInvisibleAnnotations: 
      io.vertx.docgen.Source()