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.RxifiedExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.RxifiedExamples
  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.RxifiedExamples this
         0: .line 32
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/RxifiedExamples;

  public void toObservable(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 35
            aload 1 /* vertx */
            invokevirtual io.vertx.rxjava.core.Vertx.fileSystem:()Lio/vertx/rxjava/core/file/FileSystem;
            astore 2 /* fs */
        start local 2 // io.vertx.rxjava.core.file.FileSystem fs
         1: .line 36
            aload 2 /* fs */
            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/RxifiedExamples.lambda$0(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokevirtual io.vertx.rxjava.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;Lio/vertx/core/Handler;)Lio/vertx/rxjava/core/file/FileSystem;
            pop
         2: .line 41
            return
        end local 2 // io.vertx.rxjava.core.file.FileSystem fs
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    3     0   this  Lexamples/RxifiedExamples;
            0    3     1  vertx  Lio/vertx/rxjava/core/Vertx;
            1    3     2     fs  Lio/vertx/rxjava/core/file/FileSystem;
    MethodParameters:
       Name  Flags
      vertx  

  private static void checkAuth(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.Handler handler
         0: .line 44
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 0 // io.vertx.core.Handler handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public void delayToObservable(io.vertx.rxjava.core.http.HttpServer);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpServer server
         0: .line 48
            aload 1 /* server */
            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/RxifiedExamples.lambda$2(Lio/vertx/rxjava/core/http/HttpServerRequest;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
            invokevirtual io.vertx.rxjava.core.http.HttpServer.requestHandler:(Lio/vertx/core/Handler;)Lio/vertx/rxjava/core/http/HttpServer;
            pop
         1: .line 68
            return
        end local 1 // io.vertx.rxjava.core.http.HttpServer server
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lexamples/RxifiedExamples;
            0    2     1  server  Lio/vertx/rxjava/core/http/HttpServer;
    MethodParameters:
        Name  Flags
      server  

  public void single(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 73
            aload 1 /* vertx */
         1: .line 74
            invokevirtual io.vertx.rxjava.core.Vertx.createHttpServer:()Lio/vertx/rxjava/core/http/HttpServer;
         2: .line 75
            sipush 1234
            ldc "localhost"
            invokevirtual io.vertx.rxjava.core.http.HttpServer.rxListen:(ILjava/lang/String;)Lrx/Single;
         3: .line 73
            astore 2 /* single */
        start local 2 // rx.Single single
         4: .line 78
            aload 2 /* single */
         5: .line 80
            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/RxifiedExamples.lambda$5(Lio/vertx/rxjava/core/http/HttpServer;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpServer;)V
         6: .line 83
            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/RxifiedExamples.lambda$6(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         7: .line 79
            invokevirtual rx.Single.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;)Lrx/Subscription;
            pop
         8: .line 87
            return
        end local 2 // rx.Single single
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    9     0    this  Lexamples/RxifiedExamples;
            0    9     1   vertx  Lio/vertx/rxjava/core/Vertx;
            4    9     2  single  Lrx/Single<Lio/vertx/rxjava/core/http/HttpServer;>;
    MethodParameters:
       Name  Flags
      vertx  

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

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

  public void schedulerHook(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 100
            aload 1 /* vertx */
            invokestatic io.vertx.rxjava.core.RxHelper.schedulerHook:(Lio/vertx/rxjava/core/Vertx;)Lrx/plugins/RxJavaSchedulersHook;
            astore 2 /* hook */
        start local 2 // rx.plugins.RxJavaSchedulersHook hook
         1: .line 101
            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/RxifiedExamples.lambda$7(Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler; (6)
                  (Lrx/Scheduler;)Lrx/Scheduler;
            invokestatic rx.plugins.RxJavaHooks.setOnIOScheduler:(Lrx/functions/Func1;)V
         2: .line 102
            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/RxifiedExamples.lambda$8(Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler; (6)
                  (Lrx/Scheduler;)Lrx/Scheduler;
            invokestatic rx.plugins.RxJavaHooks.setOnNewThreadScheduler:(Lrx/functions/Func1;)V
         3: .line 103
            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/RxifiedExamples.lambda$9(Lrx/plugins/RxJavaSchedulersHook;Lrx/Scheduler;)Lrx/Scheduler; (6)
                  (Lrx/Scheduler;)Lrx/Scheduler;
            invokestatic rx.plugins.RxJavaHooks.setOnComputationScheduler:(Lrx/functions/Func1;)V
         4: .line 104
            return
        end local 2 // rx.plugins.RxJavaSchedulersHook hook
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lexamples/RxifiedExamples;
            0    5     1  vertx  Lio/vertx/rxjava/core/Vertx;
            1    5     2   hook  Lrx/plugins/RxJavaSchedulersHook;
    MethodParameters:
       Name  Flags
      vertx  

  public void unmarshaller(io.vertx.rxjava.core.file.FileSystem);
    descriptor: (Lio/vertx/rxjava/core/file/FileSystem;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.file.FileSystem fileSystem
         0: .line 107
            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/RxifiedExamples.lambda$10(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokevirtual io.vertx.rxjava.core.file.FileSystem.open:(Ljava/lang/String;Lio/vertx/core/file/OpenOptions;Lio/vertx/core/Handler;)Lio/vertx/rxjava/core/file/FileSystem;
            pop
         1: .line 116
            return
        end local 1 // io.vertx.rxjava.core.file.FileSystem fileSystem
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lexamples/RxifiedExamples;
            0    2     1  fileSystem  Lio/vertx/rxjava/core/file/FileSystem;
    MethodParameters:
            Name  Flags
      fileSystem  

  public void deployVerticle(io.vertx.rxjava.core.Vertx, io.vertx.core.Verticle);
    descriptor: (Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
        start local 2 // io.vertx.core.Verticle verticle
         0: .line 119
            aload 1 /* vertx */
            aload 2 /* verticle */
            invokestatic io.vertx.rxjava.core.RxHelper.deployVerticle:(Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;)Lrx/Observable;
            astore 3 /* deployment */
        start local 3 // rx.Observable deployment
         1: .line 121
            aload 3 /* deployment */
            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/RxifiedExamples.lambda$12(Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
         2: .line 123
            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/RxifiedExamples.lambda$13(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         3: .line 121
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;)Lrx/Subscription;
            pop
         4: .line 126
            return
        end local 3 // rx.Observable deployment
        end local 2 // io.vertx.core.Verticle verticle
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lexamples/RxifiedExamples;
            0    5     1       vertx  Lio/vertx/rxjava/core/Vertx;
            0    5     2    verticle  Lio/vertx/core/Verticle;
            1    5     3  deployment  Lrx/Observable<Ljava/lang/String;>;
    MethodParameters:
          Name  Flags
      vertx     
      verticle  

  public void get(io.vertx.rxjava.core.http.HttpClient);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpClient client
         0: .line 129
            aload 1 /* client */
         1: .line 130
            getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
            ldc "http://the-server"
            invokevirtual io.vertx.rxjava.core.http.HttpClient.rxRequest:(Lio/vertx/core/http/HttpMethod;Ljava/lang/String;)Lrx/Single;
         2: .line 131
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientRequest.rxSend()Lrx/Single; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientRequest;)Lrx/Single;
            invokevirtual rx.Single.flatMap:(Lrx/functions/Func1;)Lrx/Single;
         3: .line 129
            astore 2 /* get */
        start local 2 // rx.Single get
         4: .line 134
            aload 2 /* get */
            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/RxifiedExamples.lambda$15(Lio/vertx/rxjava/core/http/HttpClientResponse;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpClientResponse;)V
         5: .line 136
            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/RxifiedExamples.lambda$16(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         6: .line 134
            invokevirtual rx.Single.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;)Lrx/Subscription;
            pop
         7: .line 139
            return
        end local 2 // rx.Single get
        end local 1 // io.vertx.rxjava.core.http.HttpClient client
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lexamples/RxifiedExamples;
            0    8     1  client  Lio/vertx/rxjava/core/http/HttpClient;
            4    8     2     get  Lrx/Single<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
        Name  Flags
      client  

  public void embedded();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // examples.RxifiedExamples this
         0: .line 142
            invokestatic io.vertx.rxjava.core.Vertx.vertx:()Lio/vertx/rxjava/core/Vertx;
            pop
         1: .line 143
            return
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lexamples/RxifiedExamples;

  public void verticle();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // examples.RxifiedExamples this
         0: .line 151
            return
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/RxifiedExamples;

  public void rxStart();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // examples.RxifiedExamples this
         0: .line 162
            return
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/RxifiedExamples;

  public void eventBusMessages(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 165
            aload 1 /* vertx */
            invokevirtual io.vertx.rxjava.core.Vertx.eventBus:()Lio/vertx/rxjava/core/eventbus/EventBus;
            astore 2 /* eb */
        start local 2 // io.vertx.rxjava.core.eventbus.EventBus eb
         1: .line 166
            aload 2 /* eb */
            ldc "the-address"
            invokevirtual io.vertx.rxjava.core.eventbus.EventBus.consumer:(Ljava/lang/String;)Lio/vertx/rxjava/core/eventbus/MessageConsumer;
            astore 3 /* consumer */
        start local 3 // io.vertx.rxjava.core.eventbus.MessageConsumer consumer
         2: .line 167
            aload 3 /* consumer */
            invokevirtual io.vertx.rxjava.core.eventbus.MessageConsumer.toObservable:()Lrx/Observable;
            astore 4 /* observable */
        start local 4 // rx.Observable observable
         3: .line 168
            aload 4 /* 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/RxifiedExamples.lambda$17(Lio/vertx/rxjava/core/eventbus/Message;)V (6)
                  (Lio/vertx/rxjava/core/eventbus/Message;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            astore 5 /* sub */
        start local 5 // rx.Subscription sub
         4: .line 173
            aload 1 /* vertx */
            ldc 10000
            aload 5 /* sub */
            invokedynamic handle(Lrx/Subscription;)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/RxifiedExamples.lambda$18(Lrx/Subscription;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokevirtual io.vertx.rxjava.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
            pop2
         5: .line 176
            return
        end local 5 // rx.Subscription sub
        end local 4 // rx.Observable observable
        end local 3 // io.vertx.rxjava.core.eventbus.MessageConsumer consumer
        end local 2 // io.vertx.rxjava.core.eventbus.EventBus eb
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lexamples/RxifiedExamples;
            0    6     1       vertx  Lio/vertx/rxjava/core/Vertx;
            1    6     2          eb  Lio/vertx/rxjava/core/eventbus/EventBus;
            2    6     3    consumer  Lio/vertx/rxjava/core/eventbus/MessageConsumer<Ljava/lang/String;>;
            3    6     4  observable  Lrx/Observable<Lio/vertx/rxjava/core/eventbus/Message<Ljava/lang/String;>;>;
            4    6     5         sub  Lrx/Subscription;
    MethodParameters:
       Name  Flags
      vertx  

  public void eventBusBodies(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 179
            aload 1 /* vertx */
            invokevirtual io.vertx.rxjava.core.Vertx.eventBus:()Lio/vertx/rxjava/core/eventbus/EventBus;
            astore 2 /* eb */
        start local 2 // io.vertx.rxjava.core.eventbus.EventBus eb
         1: .line 180
            aload 2 /* eb */
            ldc "the-address"
            invokevirtual io.vertx.rxjava.core.eventbus.EventBus.consumer:(Ljava/lang/String;)Lio/vertx/rxjava/core/eventbus/MessageConsumer;
            astore 3 /* consumer */
        start local 3 // io.vertx.rxjava.core.eventbus.MessageConsumer consumer
         2: .line 181
            aload 3 /* consumer */
            invokevirtual io.vertx.rxjava.core.eventbus.MessageConsumer.bodyStream:()Lio/vertx/rxjava/core/streams/ReadStream;
            invokeinterface io.vertx.rxjava.core.streams.ReadStream.toObservable:()Lrx/Observable;
            pop
         3: .line 182
            return
        end local 3 // io.vertx.rxjava.core.eventbus.MessageConsumer consumer
        end local 2 // io.vertx.rxjava.core.eventbus.EventBus eb
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lexamples/RxifiedExamples;
            0    4     1     vertx  Lio/vertx/rxjava/core/Vertx;
            1    4     2        eb  Lio/vertx/rxjava/core/eventbus/EventBus;
            2    4     3  consumer  Lio/vertx/rxjava/core/eventbus/MessageConsumer<Ljava/lang/String;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void eventBusMapReduce(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 185
            aload 1 /* vertx */
            invokevirtual io.vertx.rxjava.core.Vertx.eventBus:()Lio/vertx/rxjava/core/eventbus/EventBus;
         1: .line 186
            ldc "heat-sensor"
            invokevirtual io.vertx.rxjava.core.eventbus.EventBus.consumer:(Ljava/lang/String;)Lio/vertx/rxjava/core/eventbus/MessageConsumer;
         2: .line 187
            invokevirtual io.vertx.rxjava.core.eventbus.MessageConsumer.bodyStream:()Lio/vertx/rxjava/core/streams/ReadStream;
         3: .line 188
            invokeinterface io.vertx.rxjava.core.streams.ReadStream.toObservable:()Lrx/Observable;
         4: .line 185
            astore 2 /* observable */
        start local 2 // rx.Observable observable
         5: .line 190
            aload 2 /* observable */
         6: .line 191
            lconst_1
            getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
            invokevirtual rx.Observable.buffer:(JLjava/util/concurrent/TimeUnit;)Lrx/Observable;
         7: .line 192
            invokedynamic call()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/RxifiedExamples.lambda$19(Ljava/util/List;)Ljava/lang/Double; (6)
                  (Ljava/util/List;)Ljava/lang/Double;
            invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
         8: .line 195
            aload 1 /* vertx */
            invokedynamic call(Lio/vertx/rxjava/core/Vertx;)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/RxifiedExamples.lambda$21(Lio/vertx/rxjava/core/Vertx;Ljava/lang/Double;)V (6)
                  (Ljava/lang/Double;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         9: .line 198
            return
        end local 2 // rx.Observable observable
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0        this  Lexamples/RxifiedExamples;
            0   10     1       vertx  Lio/vertx/rxjava/core/Vertx;
            5   10     2  observable  Lrx/Observable<Ljava/lang/Double;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void websocketServer(io.vertx.rxjava.core.http.HttpServer);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpServer server
         0: .line 201
            aload 1 /* server */
            invokevirtual io.vertx.rxjava.core.http.HttpServer.webSocketStream:()Lio/vertx/rxjava/core/streams/ReadStream;
            invokeinterface io.vertx.rxjava.core.streams.ReadStream.toObservable:()Lrx/Observable;
            astore 2 /* socketObservable */
        start local 2 // rx.Observable socketObservable
         1: .line 202
            aload 2 /* socketObservable */
         2: .line 203
            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/RxifiedExamples.lambda$22(Lio/vertx/rxjava/core/http/ServerWebSocket;)V (6)
                  (Lio/vertx/rxjava/core/http/ServerWebSocket;)V
         3: .line 204
            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/RxifiedExamples.lambda$23(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         4: .line 205
            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/RxifiedExamples.lambda$24()V (6)
                  ()V
         5: .line 202
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;Lrx/functions/Action0;)Lrx/Subscription;
            pop
         6: .line 209
            return
        end local 2 // rx.Observable socketObservable
        end local 1 // io.vertx.rxjava.core.http.HttpServer server
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lexamples/RxifiedExamples;
            0    7     1            server  Lio/vertx/rxjava/core/http/HttpServer;
            1    7     2  socketObservable  Lrx/Observable<Lio/vertx/rxjava/core/http/ServerWebSocket;>;
    MethodParameters:
        Name  Flags
      server  

  public void websocketServerBuffer(rx.Observable<io.vertx.rxjava.core.http.ServerWebSocket>);
    descriptor: (Lrx/Observable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // rx.Observable socketObservable
         0: .line 212
            aload 1 /* socketObservable */
         1: .line 213
            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/RxifiedExamples.lambda$25(Lio/vertx/rxjava/core/http/ServerWebSocket;)V (6)
                  (Lio/vertx/rxjava/core/http/ServerWebSocket;)V
         2: .line 212
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         3: .line 220
            return
        end local 1 // rx.Observable socketObservable
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0              this  Lexamples/RxifiedExamples;
            0    4     1  socketObservable  Lrx/Observable<Lio/vertx/rxjava/core/http/ServerWebSocket;>;
    Signature: (Lrx/Observable<Lio/vertx/rxjava/core/http/ServerWebSocket;>;)V
    MethodParameters:
                  Name  Flags
      socketObservable  

  public void websocketClient(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 223
            aload 1 /* vertx */
            new io.vertx.core.http.HttpClientOptions
            dup
            invokespecial io.vertx.core.http.HttpClientOptions.<init>:()V
            invokevirtual io.vertx.rxjava.core.Vertx.createHttpClient:(Lio/vertx/core/http/HttpClientOptions;)Lio/vertx/rxjava/core/http/HttpClient;
            astore 2 /* client */
        start local 2 // io.vertx.rxjava.core.http.HttpClient client
         1: .line 224
            aload 2 /* client */
            sipush 8080
            ldc "localhost"
            ldc "/the_uri"
            invokevirtual io.vertx.rxjava.core.http.HttpClient.rxWebSocket:(ILjava/lang/String;Ljava/lang/String;)Lrx/Single;
         2: .line 225
            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/RxifiedExamples.lambda$27(Lio/vertx/rxjava/core/http/WebSocket;)V (6)
                  (Lio/vertx/rxjava/core/http/WebSocket;)V
         3: .line 228
            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/RxifiedExamples.lambda$28(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         4: .line 224
            invokevirtual rx.Single.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;)Lrx/Subscription;
            pop
         5: .line 232
            return
        end local 2 // io.vertx.rxjava.core.http.HttpClient client
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0    this  Lexamples/RxifiedExamples;
            0    6     1   vertx  Lio/vertx/rxjava/core/Vertx;
            1    6     2  client  Lio/vertx/rxjava/core/http/HttpClient;
    MethodParameters:
       Name  Flags
      vertx  

  public void websocketClientBuffer(rx.Observable<io.vertx.rxjava.core.http.WebSocket>);
    descriptor: (Lrx/Observable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // rx.Observable socketObservable
         0: .line 235
            aload 1 /* socketObservable */
         1: .line 236
            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/RxifiedExamples.lambda$29(Lio/vertx/rxjava/core/http/WebSocket;)V (6)
                  (Lio/vertx/rxjava/core/http/WebSocket;)V
         2: .line 235
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         3: .line 243
            return
        end local 1 // rx.Observable socketObservable
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0              this  Lexamples/RxifiedExamples;
            0    4     1  socketObservable  Lrx/Observable<Lio/vertx/rxjava/core/http/WebSocket;>;
    Signature: (Lrx/Observable<Lio/vertx/rxjava/core/http/WebSocket;>;)V
    MethodParameters:
                  Name  Flags
      socketObservable  

  public void httpClientRequest(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 246
            aload 1 /* vertx */
            new io.vertx.core.http.HttpClientOptions
            dup
            invokespecial io.vertx.core.http.HttpClientOptions.<init>:()V
            invokevirtual io.vertx.rxjava.core.Vertx.createHttpClient:(Lio/vertx/core/http/HttpClientOptions;)Lio/vertx/rxjava/core/http/HttpClient;
            astore 2 /* client */
        start local 2 // io.vertx.rxjava.core.http.HttpClient client
         1: .line 247
            aload 2 /* client */
         2: .line 248
            getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
            sipush 8080
            ldc "localhost"
            ldc "/the_uri"
            invokevirtual io.vertx.rxjava.core.http.HttpClient.rxRequest:(Lio/vertx/core/http/HttpMethod;ILjava/lang/String;Ljava/lang/String;)Lrx/Single;
         3: .line 249
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientRequest.rxSend()Lrx/Single; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientRequest;)Lrx/Single;
            invokevirtual rx.Single.flatMap:(Lrx/functions/Func1;)Lrx/Single;
         4: .line 247
            astore 3 /* request */
        start local 3 // rx.Single request
         5: .line 250
            aload 3 /* request */
         6: .line 251
            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/RxifiedExamples.lambda$32(Lio/vertx/rxjava/core/http/HttpClientResponse;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpClientResponse;)V
         7: .line 254
            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/RxifiedExamples.lambda$33(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
         8: .line 250
            invokevirtual rx.Single.subscribe:(Lrx/functions/Action1;Lrx/functions/Action1;)Lrx/Subscription;
            pop
         9: .line 258
            return
        end local 3 // rx.Single request
        end local 2 // io.vertx.rxjava.core.http.HttpClient client
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   10     0     this  Lexamples/RxifiedExamples;
            0   10     1    vertx  Lio/vertx/rxjava/core/Vertx;
            1   10     2   client  Lio/vertx/rxjava/core/http/HttpClient;
            5   10     3  request  Lrx/Single<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void httpClientResponse(io.vertx.rxjava.core.http.HttpClient);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpClient client
         0: .line 261
            aload 1 /* client */
         1: .line 262
            getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
            sipush 8080
            ldc "localhost"
            ldc "/the_uri"
            invokevirtual io.vertx.rxjava.core.http.HttpClient.rxRequest:(Lio/vertx/core/http/HttpMethod;ILjava/lang/String;Ljava/lang/String;)Lrx/Single;
         2: .line 263
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientRequest.rxSend()Lrx/Single; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientRequest;)Lrx/Single;
            invokevirtual rx.Single.flatMap:(Lrx/functions/Func1;)Lrx/Single;
         3: .line 261
            astore 2 /* request */
        start local 2 // rx.Single request
         4: .line 264
            aload 2 /* request */
            invokevirtual rx.Single.toObservable:()Lrx/Observable;
         5: .line 266
            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/RxifiedExamples.lambda$35(Lio/vertx/rxjava/core/http/HttpClientResponse;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpClientResponse;)V
         6: .line 265
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         7: .line 275
            return
        end local 2 // rx.Single request
        end local 1 // io.vertx.rxjava.core.http.HttpClient client
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lexamples/RxifiedExamples;
            0    8     1   client  Lio/vertx/rxjava/core/http/HttpClient;
            4    8     2  request  Lrx/Single<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
        Name  Flags
      client  

  public void httpClientResponseFlatMap(io.vertx.rxjava.core.http.HttpClient);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpClient client
         0: .line 278
            aload 1 /* client */
         1: .line 279
            getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
            sipush 8080
            ldc "localhost"
            ldc "/the_uri"
            invokevirtual io.vertx.rxjava.core.http.HttpClient.rxRequest:(Lio/vertx/core/http/HttpMethod;ILjava/lang/String;Ljava/lang/String;)Lrx/Single;
         2: .line 280
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientRequest.rxSend()Lrx/Single; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientRequest;)Lrx/Single;
            invokevirtual rx.Single.flatMap:(Lrx/functions/Func1;)Lrx/Single;
         3: .line 278
            astore 2 /* request */
        start local 2 // rx.Single request
         4: .line 281
            aload 2 /* request */
            invokevirtual rx.Single.toObservable:()Lrx/Observable;
         5: .line 282
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientResponse.toObservable()Lrx/Observable; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientResponse;)Lrx/Observable;
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         6: .line 284
            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/RxifiedExamples.lambda$39(Lio/vertx/rxjava/core/buffer/Buffer;)V (6)
                  (Lio/vertx/rxjava/core/buffer/Buffer;)V
         7: .line 283
            invokevirtual rx.Observable.forEach:(Lrx/functions/Action1;)V
         8: .line 288
            return
        end local 2 // rx.Single request
        end local 1 // io.vertx.rxjava.core.http.HttpClient client
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lexamples/RxifiedExamples;
            0    9     1   client  Lio/vertx/rxjava/core/http/HttpClient;
            4    9     2  request  Lrx/Single<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
        Name  Flags
      client  

  public void httpClientResponseFlatMapUnmarshall(io.vertx.rxjava.core.http.HttpClient);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpClient client
         0: .line 294
            aload 1 /* client */
         1: .line 295
            getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
            sipush 8080
            ldc "localhost"
            ldc "/the_uri"
            invokevirtual io.vertx.rxjava.core.http.HttpClient.rxRequest:(Lio/vertx/core/http/HttpMethod;ILjava/lang/String;Ljava/lang/String;)Lrx/Single;
         2: .line 296
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientRequest.rxSend()Lrx/Single; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientRequest;)Lrx/Single;
            invokevirtual rx.Single.flatMap:(Lrx/functions/Func1;)Lrx/Single;
         3: .line 294
            astore 2 /* request */
        start local 2 // rx.Single request
         4: .line 297
            aload 2 /* request */
            invokevirtual rx.Single.toObservable:()Lrx/Observable;
         5: .line 298
            invokedynamic call()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;
                  io/vertx/rxjava/core/http/HttpClientResponse.toObservable()Lrx/Observable; (5)
                  (Lio/vertx/rxjava/core/http/HttpClientResponse;)Lrx/Observable;
            invokevirtual rx.Observable.flatMap:(Lrx/functions/Func1;)Lrx/Observable;
         6: .line 299
            ldc Lexamples/RxifiedExamples$MyPojo;
            invokestatic io.vertx.rxjava.core.RxHelper.unmarshaller:(Ljava/lang/Class;)Lrx/Observable$Operator;
            invokevirtual rx.Observable.lift:(Lrx/Observable$Operator;)Lrx/Observable;
         7: .line 301
            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/RxifiedExamples.lambda$42(Lexamples/RxifiedExamples$MyPojo;)V (6)
                  (Lexamples/RxifiedExamples$MyPojo;)V
         8: .line 300
            invokevirtual rx.Observable.forEach:(Lrx/functions/Action1;)V
         9: .line 305
            return
        end local 2 // rx.Single request
        end local 1 // io.vertx.rxjava.core.http.HttpClient client
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   10     0     this  Lexamples/RxifiedExamples;
            0   10     1   client  Lio/vertx/rxjava/core/http/HttpClient;
            4   10     2  request  Lrx/Single<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
        Name  Flags
      client  

  public void httpServerRequest(io.vertx.rxjava.core.http.HttpServer);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpServer server
         0: .line 308
            aload 1 /* server */
            invokevirtual io.vertx.rxjava.core.http.HttpServer.requestStream:()Lio/vertx/rxjava/core/streams/ReadStream;
            invokeinterface io.vertx.rxjava.core.streams.ReadStream.toObservable:()Lrx/Observable;
            astore 2 /* requestObservable */
        start local 2 // rx.Observable requestObservable
         1: .line 309
            aload 2 /* requestObservable */
            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/RxifiedExamples.lambda$43(Lio/vertx/rxjava/core/http/HttpServerRequest;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         2: .line 312
            return
        end local 2 // rx.Observable requestObservable
        end local 1 // io.vertx.rxjava.core.http.HttpServer server
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    3     0               this  Lexamples/RxifiedExamples;
            0    3     1             server  Lio/vertx/rxjava/core/http/HttpServer;
            1    3     2  requestObservable  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpServerRequest;>;
    MethodParameters:
        Name  Flags
      server  

  public void httpServerRequestObservable(io.vertx.rxjava.core.http.HttpServer);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpServer server
         0: .line 315
            aload 1 /* server */
            invokevirtual io.vertx.rxjava.core.http.HttpServer.requestStream:()Lio/vertx/rxjava/core/streams/ReadStream;
            invokeinterface io.vertx.rxjava.core.streams.ReadStream.toObservable:()Lrx/Observable;
            astore 2 /* requestObservable */
        start local 2 // rx.Observable requestObservable
         1: .line 316
            aload 2 /* requestObservable */
            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/RxifiedExamples.lambda$44(Lio/vertx/rxjava/core/http/HttpServerRequest;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         2: .line 319
            return
        end local 2 // rx.Observable requestObservable
        end local 1 // io.vertx.rxjava.core.http.HttpServer server
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    3     0               this  Lexamples/RxifiedExamples;
            0    3     1             server  Lio/vertx/rxjava/core/http/HttpServer;
            1    3     2  requestObservable  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpServerRequest;>;
    MethodParameters:
        Name  Flags
      server  

  public void httpServerRequestObservableUnmarshall(io.vertx.rxjava.core.http.HttpServer);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.http.HttpServer server
         0: .line 322
            aload 1 /* server */
            invokevirtual io.vertx.rxjava.core.http.HttpServer.requestStream:()Lio/vertx/rxjava/core/streams/ReadStream;
            invokeinterface io.vertx.rxjava.core.streams.ReadStream.toObservable:()Lrx/Observable;
            astore 2 /* requestObservable */
        start local 2 // rx.Observable requestObservable
         1: .line 323
            aload 2 /* requestObservable */
            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/RxifiedExamples.lambda$45(Lio/vertx/rxjava/core/http/HttpServerRequest;)V (6)
                  (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         2: .line 328
            return
        end local 2 // rx.Observable requestObservable
        end local 1 // io.vertx.rxjava.core.http.HttpServer server
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    3     0               this  Lexamples/RxifiedExamples;
            0    3     1             server  Lio/vertx/rxjava/core/http/HttpServer;
            1    3     2  requestObservable  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpServerRequest;>;
    MethodParameters:
        Name  Flags
      server  

  public void timer(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 331
            aload 1 /* vertx */
            ldc 1000
            invokevirtual io.vertx.rxjava.core.Vertx.timerStream:(J)Lio/vertx/rxjava/core/TimeoutStream;
         1: .line 332
            invokevirtual io.vertx.rxjava.core.TimeoutStream.toObservable:()Lrx/Observable;
         2: .line 334
            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/RxifiedExamples.lambda$46(Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
         3: .line 333
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         4: .line 338
            return
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lexamples/RxifiedExamples;
            0    5     1  vertx  Lio/vertx/rxjava/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public void periodic(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 341
            aload 1 /* vertx */
            ldc 1000
            invokevirtual io.vertx.rxjava.core.Vertx.periodicStream:(J)Lio/vertx/rxjava/core/TimeoutStream;
         1: .line 342
            invokevirtual io.vertx.rxjava.core.TimeoutStream.toObservable:()Lrx/Observable;
         2: .line 344
            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/RxifiedExamples.lambda$47(Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
         3: .line 343
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
         4: .line 348
            return
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lexamples/RxifiedExamples;
            0    5     1  vertx  Lio/vertx/rxjava/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public void periodicUnsubscribe(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // examples.RxifiedExamples this
        start local 1 // io.vertx.rxjava.core.Vertx vertx
         0: .line 351
            aload 1 /* vertx */
            ldc 1000
            invokevirtual io.vertx.rxjava.core.Vertx.periodicStream:(J)Lio/vertx/rxjava/core/TimeoutStream;
         1: .line 352
            invokevirtual io.vertx.rxjava.core.TimeoutStream.toObservable:()Lrx/Observable;
         2: .line 353
            new examples.RxifiedExamples$1
            dup
            aload 0 /* this */
            invokespecial examples.RxifiedExamples$1.<init>:(Lexamples/RxifiedExamples;)V
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         3: .line 361
            return
        end local 1 // io.vertx.rxjava.core.Vertx vertx
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lexamples/RxifiedExamples;
            0    4     1  vertx  Lio/vertx/rxjava/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public void writeStreamSubscriberAdapter(rx.Observable<io.vertx.core.buffer.Buffer>, io.vertx.core.http.HttpServerResponse);
    descriptor: (Lrx/Observable;Lio/vertx/core/http/HttpServerResponse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // examples.RxifiedExamples this
        start local 1 // rx.Observable observable
        start local 2 // io.vertx.core.http.HttpServerResponse response
         0: .line 364
            aload 2 /* response */
            iconst_1
            invokeinterface io.vertx.core.http.HttpServerResponse.setChunked:(Z)Lio/vertx/core/http/HttpServerResponse;
            pop
         1: .line 365
            aload 2 /* response */
            invokestatic io.vertx.rx.java.RxHelper.toSubscriber:(Lio/vertx/core/streams/WriteStream;)Lio/vertx/rx/java/WriteStreamSubscriber;
            astore 3 /* subscriber */
        start local 3 // io.vertx.rx.java.WriteStreamSubscriber subscriber
         2: .line 366
            aload 1 /* observable */
            aload 3 /* subscriber */
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         3: .line 367
            return
        end local 3 // io.vertx.rx.java.WriteStreamSubscriber subscriber
        end local 2 // io.vertx.core.http.HttpServerResponse response
        end local 1 // rx.Observable observable
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lexamples/RxifiedExamples;
            0    4     1  observable  Lrx/Observable<Lio/vertx/core/buffer/Buffer;>;
            0    4     2    response  Lio/vertx/core/http/HttpServerResponse;
            2    4     3  subscriber  Lio/vertx/rx/java/WriteStreamSubscriber<Lio/vertx/core/buffer/Buffer;>;
    Signature: (Lrx/Observable<Lio/vertx/core/buffer/Buffer;>;Lio/vertx/core/http/HttpServerResponse;)V
    MethodParameters:
            Name  Flags
      observable  
      response    

  public void rxWriteStreamSubscriberAdapter(rx.Observable<io.vertx.rxjava.core.buffer.Buffer>, io.vertx.rxjava.core.http.HttpServerResponse);
    descriptor: (Lrx/Observable;Lio/vertx/rxjava/core/http/HttpServerResponse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // examples.RxifiedExamples this
        start local 1 // rx.Observable observable
        start local 2 // io.vertx.rxjava.core.http.HttpServerResponse response
         0: .line 370
            aload 2 /* response */
            iconst_1
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.setChunked:(Z)Lio/vertx/rxjava/core/http/HttpServerResponse;
            pop
         1: .line 371
            aload 1 /* observable */
            aload 2 /* response */
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.toSubscriber:()Lio/vertx/rx/java/WriteStreamSubscriber;
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         2: .line 372
            return
        end local 2 // io.vertx.rxjava.core.http.HttpServerResponse response
        end local 1 // rx.Observable observable
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lexamples/RxifiedExamples;
            0    3     1  observable  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;
            0    3     2    response  Lio/vertx/rxjava/core/http/HttpServerResponse;
    Signature: (Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;Lio/vertx/rxjava/core/http/HttpServerResponse;)V
    MethodParameters:
            Name  Flags
      observable  
      response    

  public void writeStreamSubscriberAdapterCallbacks(rx.Observable<io.vertx.rxjava.core.buffer.Buffer>, io.vertx.rxjava.core.http.HttpServerResponse);
    descriptor: (Lrx/Observable;Lio/vertx/rxjava/core/http/HttpServerResponse;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // examples.RxifiedExamples this
        start local 1 // rx.Observable observable
        start local 2 // io.vertx.rxjava.core.http.HttpServerResponse response
         0: .line 375
            aload 2 /* response */
            iconst_1
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.setChunked:(Z)Lio/vertx/rxjava/core/http/HttpServerResponse;
            pop
         1: .line 377
            aload 2 /* response */
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.toSubscriber:()Lio/vertx/rx/java/WriteStreamSubscriber;
            astore 3 /* subscriber */
        start local 3 // io.vertx.rx.java.WriteStreamSubscriber subscriber
         2: .line 379
            aload 3 /* subscriber */
            aload 2 /* response */
            invokedynamic call(Lio/vertx/rxjava/core/http/HttpServerResponse;)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/RxifiedExamples.lambda$48(Lio/vertx/rxjava/core/http/HttpServerResponse;Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokevirtual io.vertx.rx.java.WriteStreamSubscriber.onError:(Lrx/functions/Action1;)Lio/vertx/rx/java/WriteStreamSubscriber;
            pop
         3: .line 387
            aload 3 /* subscriber */
            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/RxifiedExamples.lambda$49(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokevirtual io.vertx.rx.java.WriteStreamSubscriber.onWriteStreamError:(Lrx/functions/Action1;)Lio/vertx/rx/java/WriteStreamSubscriber;
            pop
         4: .line 391
            aload 3 /* subscriber */
            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/RxifiedExamples.lambda$50()V (6)
                  ()V
            invokevirtual io.vertx.rx.java.WriteStreamSubscriber.onWriteStreamEnd:(Lrx/functions/Action0;)Lio/vertx/rx/java/WriteStreamSubscriber;
            pop
         5: .line 395
            aload 1 /* observable */
            aload 3 /* subscriber */
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         6: .line 396
            return
        end local 3 // io.vertx.rx.java.WriteStreamSubscriber subscriber
        end local 2 // io.vertx.rxjava.core.http.HttpServerResponse response
        end local 1 // rx.Observable observable
        end local 0 // examples.RxifiedExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lexamples/RxifiedExamples;
            0    7     1  observable  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;
            0    7     2    response  Lio/vertx/rxjava/core/http/HttpServerResponse;
            2    7     3  subscriber  Lio/vertx/rx/java/WriteStreamSubscriber<Lio/vertx/rxjava/core/buffer/Buffer;>;
    Signature: (Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;Lio/vertx/rxjava/core/http/HttpServerResponse;)V
    MethodParameters:
            Name  Flags
      observable  
      response    

  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 37
            aload 0 /* result */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.rxjava.core.file.AsyncFile
            astore 1 /* file */
        start local 1 // io.vertx.rxjava.core.file.AsyncFile file
         1: .line 38
            aload 1 /* file */
            invokevirtual io.vertx.rxjava.core.file.AsyncFile.toObservable:()Lrx/Observable;
            astore 2 /* observable */
        start local 2 // rx.Observable observable
         2: .line 39
            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/RxifiedExamples.lambda$1(Lio/vertx/rxjava/core/buffer/Buffer;)V (6)
                  (Lio/vertx/rxjava/core/buffer/Buffer;)V
            invokevirtual rx.Observable.forEach:(Lrx/functions/Action1;)V
        end local 2 // rx.Observable observable
        end local 1 // io.vertx.rxjava.core.file.AsyncFile file
         3: .line 40
            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/rxjava/core/file/AsyncFile;>;
            1    3     1        file  Lio/vertx/rxjava/core/file/AsyncFile;
            2    3     2  observable  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;

  private static void lambda$2(io.vertx.rxjava.core.http.HttpServerRequest);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.http.HttpServerRequest request
         0: .line 49
            aload 0 /* request */
            invokevirtual io.vertx.rxjava.core.http.HttpServerRequest.method:()Lio/vertx/core/http/HttpMethod;
            getstatic io.vertx.core.http.HttpMethod.POST:Lio/vertx/core/http/HttpMethod;
            if_acmpne 3
         1: .line 52
            aload 0 /* request */
            invokevirtual io.vertx.rxjava.core.http.HttpServerRequest.pause:()Lio/vertx/rxjava/core/http/HttpServerRequest;
            pop
         2: .line 54
            aload 0 /* request */
            invokedynamic handle(Lio/vertx/rxjava/core/http/HttpServerRequest;)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/RxifiedExamples.lambda$3(Lio/vertx/rxjava/core/http/HttpServerRequest;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokestatic examples.RxifiedExamples.checkAuth:(Lio/vertx/core/Handler;)V
         3: .line 67
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.rxjava.core.http.HttpServerRequest request
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  request  Lio/vertx/rxjava/core/http/HttpServerRequest;

  private static void lambda$5(io.vertx.rxjava.core.http.HttpServer);
    descriptor: (Lio/vertx/rxjava/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.rxjava.core.http.HttpServer server
         0: .line 82
            return
        end local 0 // io.vertx.rxjava.core.http.HttpServer server
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  server  Lio/vertx/rxjava/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 failure
         0: .line 85
            return
        end local 0 // java.lang.Throwable failure
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  failure  Ljava/lang/Throwable;

  private static rx.Scheduler lambda$7(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 101
            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$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 102
            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$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 103
            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$10(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 108
            aload 0 /* result */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.rxjava.core.file.AsyncFile
            astore 1 /* file */
        start local 1 // io.vertx.rxjava.core.file.AsyncFile file
         1: .line 109
            aload 1 /* file */
            invokevirtual io.vertx.rxjava.core.file.AsyncFile.toObservable:()Lrx/Observable;
            astore 2 /* observable */
        start local 2 // rx.Observable observable
         2: .line 110
            aload 2 /* observable */
            ldc Lexamples/RxifiedExamples$MyPojo;
            invokestatic io.vertx.rxjava.core.RxHelper.unmarshaller:(Ljava/lang/Class;)Lrx/Observable$Operator;
            invokevirtual rx.Observable.lift:(Lrx/Observable$Operator;)Lrx/Observable;
         3: .line 111
            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/RxifiedExamples.lambda$11(Lexamples/RxifiedExamples$MyPojo;)V (6)
                  (Lexamples/RxifiedExamples$MyPojo;)V
         4: .line 110
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
        end local 2 // rx.Observable observable
        end local 1 // io.vertx.rxjava.core.file.AsyncFile file
         5: .line 115
            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/rxjava/core/file/AsyncFile;>;
            1    5     1        file  Lio/vertx/rxjava/core/file/AsyncFile;
            2    5     2  observable  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;

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

  private static void lambda$13(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 err
         0: .line 125
            return
        end local 0 // java.lang.Throwable err
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   err  Ljava/lang/Throwable;

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

  private static void lambda$16(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 err
         0: .line 138
            return
        end local 0 // java.lang.Throwable err
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   err  Ljava/lang/Throwable;

  private static void lambda$17(io.vertx.rxjava.core.eventbus.Message);
    descriptor: (Lio/vertx/rxjava/core/eventbus/Message;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.eventbus.Message msg
         0: .line 170
            return
        end local 0 // io.vertx.rxjava.core.eventbus.Message msg
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   msg  Lio/vertx/rxjava/core/eventbus/Message<Ljava/lang/String;>;

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

  private static java.lang.Double lambda$19(java.util.List);
    descriptor: (Ljava/util/List;)Ljava/lang/Double;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.List samples
         0: .line 192
            aload 0 /* samples */
         1: .line 193
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
         2: .line 194
            invokedynamic applyAsDouble()Ljava/util/function/ToDoubleFunction;
              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;)D
                  examples/RxifiedExamples.lambda$20(Ljava/lang/Double;)D (6)
                  (Ljava/lang/Double;)D
            invokestatic java.util.stream.Collectors.averagingDouble:(Ljava/util/function/ToDoubleFunction;)Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.lang.Double
            areturn
        end local 0 // java.util.List samples
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0  samples  Ljava/util/List<Ljava/lang/Double;>;

  private static void lambda$21(io.vertx.rxjava.core.Vertx, java.lang.Double);
    descriptor: (Lio/vertx/rxjava/core/Vertx;Ljava/lang/Double;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=5, locals=2, args_size=2
        start local 1 // java.lang.Double heat
         0: .line 196
            aload 0
            invokevirtual io.vertx.rxjava.core.Vertx.eventBus:()Lio/vertx/rxjava/core/eventbus/EventBus;
            ldc "news-feed"
            new java.lang.StringBuilder
            dup
            ldc "Current heat is "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* heat */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual io.vertx.rxjava.core.eventbus.EventBus.send:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/rxjava/core/eventbus/EventBus;
            pop
         1: .line 197
            return
        end local 1 // java.lang.Double heat
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     1  heat  Ljava/lang/Double;

  private static void lambda$22(io.vertx.rxjava.core.http.ServerWebSocket);
    descriptor: (Lio/vertx/rxjava/core/http/ServerWebSocket;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.http.ServerWebSocket socket
         0: .line 203
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Web socket connect"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // io.vertx.rxjava.core.http.ServerWebSocket socket
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  socket  Lio/vertx/rxjava/core/http/ServerWebSocket;

  private static void lambda$23(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Throwable failure
         0: .line 204
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Should never be called"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            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$24();
    descriptor: ()V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 206
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Subscription ended or server closed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 207
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static void lambda$25(io.vertx.rxjava.core.http.ServerWebSocket);
    descriptor: (Lio/vertx/rxjava/core/http/ServerWebSocket;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.rxjava.core.http.ServerWebSocket socket
         0: .line 214
            aload 0 /* socket */
            invokevirtual io.vertx.rxjava.core.http.ServerWebSocket.toObservable:()Lrx/Observable;
            astore 1 /* dataObs */
        start local 1 // rx.Observable dataObs
         1: .line 215
            aload 1 /* dataObs */
            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/RxifiedExamples.lambda$26(Lio/vertx/rxjava/core/buffer/Buffer;)V (6)
                  (Lio/vertx/rxjava/core/buffer/Buffer;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
        end local 1 // rx.Observable dataObs
         2: .line 218
            return
        end local 0 // io.vertx.rxjava.core.http.ServerWebSocket socket
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0   socket  Lio/vertx/rxjava/core/http/ServerWebSocket;
            1    2     1  dataObs  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;

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

  private static void lambda$28(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 error
         0: .line 230
            return
        end local 0 // java.lang.Throwable error
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  error  Ljava/lang/Throwable;

  private static void lambda$29(io.vertx.rxjava.core.http.WebSocket);
    descriptor: (Lio/vertx/rxjava/core/http/WebSocket;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.rxjava.core.http.WebSocket socket
         0: .line 237
            aload 0 /* socket */
            invokevirtual io.vertx.rxjava.core.http.WebSocket.toObservable:()Lrx/Observable;
            astore 1 /* dataObs */
        start local 1 // rx.Observable dataObs
         1: .line 238
            aload 1 /* dataObs */
            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/RxifiedExamples.lambda$30(Lio/vertx/rxjava/core/buffer/Buffer;)V (6)
                  (Lio/vertx/rxjava/core/buffer/Buffer;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
        end local 1 // rx.Observable dataObs
         2: .line 241
            return
        end local 0 // io.vertx.rxjava.core.http.WebSocket socket
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0   socket  Lio/vertx/rxjava/core/http/WebSocket;
            1    2     1  dataObs  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;

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

  private static void lambda$33(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 error
         0: .line 256
            return
        end local 0 // java.lang.Throwable error
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  error  Ljava/lang/Throwable;

  private static void lambda$35(io.vertx.rxjava.core.http.HttpClientResponse);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClientResponse;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.rxjava.core.http.HttpClientResponse response
         0: .line 267
            aload 0 /* response */
            invokevirtual io.vertx.rxjava.core.http.HttpClientResponse.toObservable:()Lrx/Observable;
            astore 1 /* observable */
        start local 1 // rx.Observable observable
         1: .line 268
            aload 1 /* observable */
         2: .line 269
            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/RxifiedExamples.lambda$36(Lio/vertx/rxjava/core/buffer/Buffer;)V (6)
                  (Lio/vertx/rxjava/core/buffer/Buffer;)V
         3: .line 268
            invokevirtual rx.Observable.forEach:(Lrx/functions/Action1;)V
        end local 1 // rx.Observable observable
         4: .line 273
            return
        end local 0 // io.vertx.rxjava.core.http.HttpClientResponse response
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0    response  Lio/vertx/rxjava/core/http/HttpClientResponse;
            1    4     1  observable  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;

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

  private static void lambda$42(examples.RxifiedExamples$MyPojo);
    descriptor: (Lexamples/RxifiedExamples$MyPojo;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // examples.RxifiedExamples$MyPojo pojo
         0: .line 303
            return
        end local 0 // examples.RxifiedExamples$MyPojo pojo
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  pojo  Lexamples/RxifiedExamples$MyPojo;

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

  private static void lambda$44(io.vertx.rxjava.core.http.HttpServerRequest);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.http.HttpServerRequest request
         0: .line 317
            aload 0 /* request */
            invokevirtual io.vertx.rxjava.core.http.HttpServerRequest.toObservable:()Lrx/Observable;
            pop
         1: .line 318
            return
        end local 0 // io.vertx.rxjava.core.http.HttpServerRequest request
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  request  Lio/vertx/rxjava/core/http/HttpServerRequest;

  private static void lambda$45(io.vertx.rxjava.core.http.HttpServerRequest);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServerRequest;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.http.HttpServerRequest request
         0: .line 324
            aload 0 /* request */
         1: .line 325
            invokevirtual io.vertx.rxjava.core.http.HttpServerRequest.toObservable:()Lrx/Observable;
         2: .line 326
            ldc Lexamples/RxifiedExamples$MyPojo;
            invokestatic io.vertx.rxjava.core.RxHelper.unmarshaller:(Ljava/lang/Class;)Lrx/Observable$Operator;
            invokevirtual rx.Observable.lift:(Lrx/Observable$Operator;)Lrx/Observable;
            pop
         3: .line 327
            return
        end local 0 // io.vertx.rxjava.core.http.HttpServerRequest request
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  request  Lio/vertx/rxjava/core/http/HttpServerRequest;

  private static void lambda$46(java.lang.Long);
    descriptor: (Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Long id
         0: .line 335
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Callback after 1 second"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 336
            return
        end local 0 // java.lang.Long id
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0    id  Ljava/lang/Long;

  private static void lambda$47(java.lang.Long);
    descriptor: (Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Long id
         0: .line 345
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Callback every second"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 346
            return
        end local 0 // java.lang.Long id
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0    id  Ljava/lang/Long;

  private static void lambda$48(io.vertx.rxjava.core.http.HttpServerResponse, java.lang.Throwable);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServerResponse;Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // java.lang.Throwable throwable
         0: .line 380
            aload 0
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.headWritten:()Z
            ifne 2
            aload 0
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.closed:()Z
            ifeq 2
         1: .line 381
            aload 0
            sipush 500
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.setStatusCode:(I)Lio/vertx/rxjava/core/http/HttpServerResponse;
            ldc "oops"
            invokevirtual io.vertx.rxjava.core.http.HttpServerResponse.end:(Ljava/lang/String;)V
         2: .line 385
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable throwable
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     1  throwable  Ljava/lang/Throwable;

  private static void lambda$49(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 throwable
         0: .line 389
            return
        end local 0 // java.lang.Throwable throwable
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0  throwable  Ljava/lang/Throwable;

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

  private static void lambda$1(io.vertx.rxjava.core.buffer.Buffer);
    descriptor: (Lio/vertx/rxjava/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.rxjava.core.buffer.Buffer data
         0: .line 39
            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"
            invokevirtual io.vertx.rxjava.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.rxjava.core.buffer.Buffer data
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  data  Lio/vertx/rxjava/core/buffer/Buffer;

  private static void lambda$3(io.vertx.rxjava.core.http.HttpServerRequest, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/rxjava/core/http/HttpServerRequest;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 1 // io.vertx.core.AsyncResult res
         0: .line 57
            aload 0
            invokevirtual io.vertx.rxjava.core.http.HttpServerRequest.resume:()Lio/vertx/rxjava/core/http/HttpServerRequest;
            pop
         1: .line 59
            aload 1 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         2: .line 60
            aload 0
            invokevirtual io.vertx.rxjava.core.http.HttpServerRequest.toObservable:()Lrx/Observable;
            astore 2 /* observable */
        start local 2 // rx.Observable observable
         3: .line 61
            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/RxifiedExamples.lambda$4(Lio/vertx/rxjava/core/buffer/Buffer;)V (6)
                  (Lio/vertx/rxjava/core/buffer/Buffer;)V
            invokevirtual rx.Observable.subscribe:(Lrx/functions/Action1;)Lrx/Subscription;
            pop
        end local 2 // rx.Observable observable
         4: .line 65
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     1         res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
            3    4     2  observable  Lrx/Observable<Lio/vertx/rxjava/core/buffer/Buffer;>;

  private static void lambda$11(examples.RxifiedExamples$MyPojo);
    descriptor: (Lexamples/RxifiedExamples$MyPojo;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // examples.RxifiedExamples$MyPojo mypojo
         0: .line 113
            return
        end local 0 // examples.RxifiedExamples$MyPojo mypojo
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  mypojo  Lexamples/RxifiedExamples$MyPojo;

  private static double lambda$20(java.lang.Double);
    descriptor: (Ljava/lang/Double;)D
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Double d
         0: .line 194
            aload 0 /* d */
            invokevirtual java.lang.Double.doubleValue:()D
            dreturn
        end local 0 // java.lang.Double d
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     d  Ljava/lang/Double;

  private static void lambda$26(io.vertx.rxjava.core.buffer.Buffer);
    descriptor: (Lio/vertx/rxjava/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.rxjava.core.buffer.Buffer buffer
         0: .line 216
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got message "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* buffer */
            ldc "UTF-8"
            invokevirtual io.vertx.rxjava.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
         1: .line 217
            return
        end local 0 // io.vertx.rxjava.core.buffer.Buffer buffer
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  buffer  Lio/vertx/rxjava/core/buffer/Buffer;

  private static void lambda$30(io.vertx.rxjava.core.buffer.Buffer);
    descriptor: (Lio/vertx/rxjava/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.rxjava.core.buffer.Buffer buffer
         0: .line 239
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Got message "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* buffer */
            ldc "UTF-8"
            invokevirtual io.vertx.rxjava.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
         1: .line 240
            return
        end local 0 // io.vertx.rxjava.core.buffer.Buffer buffer
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0  buffer  Lio/vertx/rxjava/core/buffer/Buffer;

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

  private static void lambda$4(io.vertx.rxjava.core.buffer.Buffer);
    descriptor: (Lio/vertx/rxjava/core/buffer/Buffer;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.buffer.Buffer buff
         0: .line 63
            return
        end local 0 // io.vertx.rxjava.core.buffer.Buffer buff
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  buff  Lio/vertx/rxjava/core/buffer/Buffer;
}
SourceFile: "RxifiedExamples.java"
NestMembers:
  examples.RxifiedExamples$1  examples.RxifiedExamples$1MyVerticle  examples.RxifiedExamples$2MyVerticle  examples.RxifiedExamples$MyPojo
InnerClasses:
  examples.RxifiedExamples$1
  MyVerticle = examples.RxifiedExamples$1MyVerticle
  MyVerticle = examples.RxifiedExamples$2MyVerticle
  private MyPojo = examples.RxifiedExamples$MyPojo of examples.RxifiedExamples
  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()