io.vertx/vertx-rx-java/3.8.0 : io/vertx/rxjava/core/RxHelper.class

RxHelper
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 io.vertx.rxjava.core.RxHelper
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.rxjava.core.RxHelper
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.rxjava.core.RxHelper this
         0: .line 21
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.vertx.rxjava.core.RxHelper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/rxjava/core/RxHelper;

  public static rx.plugins.RxJavaSchedulersHook schedulerHook(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)Lrx/plugins/RxJavaSchedulersHook;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 31
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tio.vertx.rx cannot be resolved\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
       Name  Flags
      vertx  

  public static rx.plugins.RxJavaSchedulersHook schedulerHook(io.vertx.rxjava.core.Context);
    descriptor: (Lio/vertx/rxjava/core/Context;)Lrx/plugins/RxJavaSchedulersHook;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 41
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tio.vertx.rx cannot be resolved\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
         Name  Flags
      context  

  public static rx.Scheduler scheduler(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)Lrx/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 51
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tContextScheduler cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
       Name  Flags
      vertx  

  public static rx.Scheduler scheduler(io.vertx.rxjava.core.WorkerExecutor);
    descriptor: (Lio/vertx/rxjava/core/WorkerExecutor;)Lrx/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 61
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tContextScheduler cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
          Name  Flags
      executor  

  public static rx.Scheduler scheduler(io.vertx.rxjava.core.Context);
    descriptor: (Lio/vertx/rxjava/core/Context;)Lrx/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 71
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tContextScheduler cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
         Name  Flags
      context  

  public static rx.Scheduler blockingScheduler(io.vertx.rxjava.core.Vertx);
    descriptor: (Lio/vertx/rxjava/core/Vertx;)Lrx/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 82
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tContextScheduler cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
       Name  Flags
      vertx  

  public static rx.Scheduler blockingScheduler(io.vertx.rxjava.core.Vertx, boolean);
    descriptor: (Lio/vertx/rxjava/core/Vertx;Z)Lrx/Scheduler;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=2
         0: .line 96
            new java.lang.Error
            dup
            ldc "Unresolved compilation problem: \n\tContextScheduler cannot be resolved to a type\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    MethodParameters:
         Name  Flags
      vertx    
      ordered  

  public static <T> rx.Observable$Operator<T, io.vertx.rxjava.core.buffer.Buffer> unmarshaller(java.lang.Class<T>);
    descriptor: (Ljava/lang/Class;)Lrx/Observable$Operator;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 113
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tType mismatch: cannot convert from new UnmarshallerOperator<T,Buffer>(){} to Observable.Operator<T,Buffer>\n\tUnmarshallerOperator cannot be resolved to a type\n\tThe method unwrap(Buffer) of type new UnmarshallerOperator<T,Buffer>(){} must override or implement a supertype method\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>(Ljava/lang/Class<TT;>;)Lrx/Observable$Operator<TT;Lio/vertx/rxjava/core/buffer/Buffer;>;
    MethodParameters:
            Name  Flags
      mappedType  

  public static rx.Observable<io.vertx.rxjava.core.http.HttpClientResponse> get(io.vertx.rxjava.core.http.HttpClient, java.lang.String);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;)Lrx/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.rxjava.core.http.HttpClient client
        start local 1 // java.lang.String requestURI
         0: .line 125
            aload 0 /* client */
            aload 1 /* requestURI */
            invokedynamic call(Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;)Lrx/Observable$OnSubscribe;
              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
                  io/vertx/rxjava/core/RxHelper.lambda$0(Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Lrx/Subscriber;)V (6)
                  (Lrx/Subscriber;)V
            invokestatic rx.Observable.create:(Lrx/Observable$OnSubscribe;)Lrx/Observable;
            areturn
        end local 1 // java.lang.String requestURI
        end local 0 // io.vertx.rxjava.core.http.HttpClient client
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0      client  Lio/vertx/rxjava/core/http/HttpClient;
            0    1     1  requestURI  Ljava/lang/String;
    Signature: (Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;)Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
            Name  Flags
      client      
      requestURI  

  public static rx.Observable<io.vertx.rxjava.core.http.HttpClientResponse> get(io.vertx.rxjava.core.http.HttpClient, java.lang.String, java.lang.String);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Ljava/lang/String;)Lrx/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.rxjava.core.http.HttpClient client
        start local 1 // java.lang.String host
        start local 2 // java.lang.String requestURI
         0: .line 137
            aload 0 /* client */
            aload 1 /* host */
            aload 2 /* requestURI */
            invokedynamic call(Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Ljava/lang/String;)Lrx/Observable$OnSubscribe;
              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
                  io/vertx/rxjava/core/RxHelper.lambda$1(Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Ljava/lang/String;Lrx/Subscriber;)V (6)
                  (Lrx/Subscriber;)V
            invokestatic rx.Observable.create:(Lrx/Observable$OnSubscribe;)Lrx/Observable;
            areturn
        end local 2 // java.lang.String requestURI
        end local 1 // java.lang.String host
        end local 0 // io.vertx.rxjava.core.http.HttpClient client
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0      client  Lio/vertx/rxjava/core/http/HttpClient;
            0    1     1        host  Ljava/lang/String;
            0    1     2  requestURI  Ljava/lang/String;
    Signature: (Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Ljava/lang/String;)Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
            Name  Flags
      client      
      host        
      requestURI  

  public static rx.Observable<io.vertx.rxjava.core.http.HttpClientResponse> get(io.vertx.rxjava.core.http.HttpClient, int, java.lang.String, java.lang.String);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;)Lrx/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // io.vertx.rxjava.core.http.HttpClient client
        start local 1 // int port
        start local 2 // java.lang.String host
        start local 3 // java.lang.String requestURI
         0: .line 149
            aload 0 /* client */
            iload 1 /* port */
            aload 2 /* host */
            aload 3 /* requestURI */
            invokedynamic call(Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;)Lrx/Observable$OnSubscribe;
              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
                  io/vertx/rxjava/core/RxHelper.lambda$2(Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lrx/Subscriber;)V (6)
                  (Lrx/Subscriber;)V
            invokestatic rx.Observable.create:(Lrx/Observable$OnSubscribe;)Lrx/Observable;
            areturn
        end local 3 // java.lang.String requestURI
        end local 2 // java.lang.String host
        end local 1 // int port
        end local 0 // io.vertx.rxjava.core.http.HttpClient client
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0      client  Lio/vertx/rxjava/core/http/HttpClient;
            0    1     1        port  I
            0    1     2        host  Ljava/lang/String;
            0    1     3  requestURI  Ljava/lang/String;
    Signature: (Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;)Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
            Name  Flags
      client      
      port        
      host        
      requestURI  

  public static rx.Observable<io.vertx.rxjava.core.http.HttpClientResponse> get(io.vertx.rxjava.core.http.HttpClient, int, java.lang.String, java.lang.String, io.vertx.rxjava.core.MultiMap);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lio/vertx/rxjava/core/MultiMap;)Lrx/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=5, args_size=5
        start local 0 // io.vertx.rxjava.core.http.HttpClient client
        start local 1 // int port
        start local 2 // java.lang.String host
        start local 3 // java.lang.String requestURI
        start local 4 // io.vertx.rxjava.core.MultiMap headers
         0: .line 172
            aload 0 /* client */
            iload 1 /* port */
            aload 2 /* host */
            aload 3 /* requestURI */
            aload 4 /* headers */
            invokedynamic call(Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lio/vertx/rxjava/core/MultiMap;)Lrx/Observable$OnSubscribe;
              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
                  io/vertx/rxjava/core/RxHelper.lambda$3(Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lio/vertx/rxjava/core/MultiMap;Lrx/Subscriber;)V (6)
                  (Lrx/Subscriber;)V
            invokestatic rx.Observable.create:(Lrx/Observable$OnSubscribe;)Lrx/Observable;
            areturn
        end local 4 // io.vertx.rxjava.core.MultiMap headers
        end local 3 // java.lang.String requestURI
        end local 2 // java.lang.String host
        end local 1 // int port
        end local 0 // io.vertx.rxjava.core.http.HttpClient client
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0      client  Lio/vertx/rxjava/core/http/HttpClient;
            0    1     1        port  I
            0    1     2        host  Ljava/lang/String;
            0    1     3  requestURI  Ljava/lang/String;
            0    1     4     headers  Lio/vertx/rxjava/core/MultiMap;
    Signature: (Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lio/vertx/rxjava/core/MultiMap;)Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
    MethodParameters:
            Name  Flags
      client      
      port        
      host        
      requestURI  
      headers     

  public static rx.Observable<java.lang.String> deployVerticle(io.vertx.rxjava.core.Vertx, io.vertx.core.Verticle);
    descriptor: (Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;)Lrx/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.rxjava.core.Vertx vertx
        start local 1 // io.vertx.core.Verticle verticle
         0: .line 190
            aload 0 /* vertx */
            aload 1 /* verticle */
            new io.vertx.core.DeploymentOptions
            dup
            invokespecial io.vertx.core.DeploymentOptions.<init>:()V
            invokestatic io.vertx.rxjava.core.RxHelper.deployVerticle:(Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lrx/Observable;
            areturn
        end local 1 // io.vertx.core.Verticle verticle
        end local 0 // io.vertx.rxjava.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    1     0     vertx  Lio/vertx/rxjava/core/Vertx;
            0    1     1  verticle  Lio/vertx/core/Verticle;
    Signature: (Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;)Lrx/Observable<Ljava/lang/String;>;
    MethodParameters:
          Name  Flags
      vertx     
      verticle  

  public static rx.Observable<java.lang.String> deployVerticle(io.vertx.rxjava.core.Vertx, io.vertx.core.Verticle, io.vertx.core.DeploymentOptions);
    descriptor: (Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lrx/Observable;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 203
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tObservableFuture cannot be resolved to a type\n\tio.vertx.rx cannot be resolved\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: (Lio/vertx/rxjava/core/Vertx;Lio/vertx/core/Verticle;Lio/vertx/core/DeploymentOptions;)Lrx/Observable<Ljava/lang/String;>;
    MethodParameters:
          Name  Flags
      vertx     
      verticle  
      options   

  private static void lambda$0(io.vertx.rxjava.core.http.HttpClient, java.lang.String, rx.Subscriber);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Lrx/Subscriber;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=5, args_size=3
        start local 2 // rx.Subscriber subscriber
         0: .line 126
            aload 0
            aload 1
            invokevirtual io.vertx.rxjava.core.http.HttpClient.get:(Ljava/lang/String;)Lio/vertx/rxjava/core/http/HttpClientRequest;
            astore 3 /* req */
        start local 3 // io.vertx.rxjava.core.http.HttpClientRequest req
         1: .line 127
            aload 3 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.toObservable:()Lrx/Observable;
            astore 4 /* resp */
        start local 4 // rx.Observable resp
         2: .line 128
            aload 4 /* resp */
            aload 2 /* subscriber */
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         3: .line 129
            aload 3 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.end:()V
        end local 4 // rx.Observable resp
        end local 3 // io.vertx.rxjava.core.http.HttpClientRequest req
         4: .line 130
            return
        end local 2 // rx.Subscriber subscriber
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     2  subscriber  Lrx/Subscriber<-Lio/vertx/rxjava/core/http/HttpClientResponse;>;
            1    4     3         req  Lio/vertx/rxjava/core/http/HttpClientRequest;
            2    4     4        resp  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;

  private static void lambda$1(io.vertx.rxjava.core.http.HttpClient, java.lang.String, java.lang.String, rx.Subscriber);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;Ljava/lang/String;Ljava/lang/String;Lrx/Subscriber;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=6, args_size=4
        start local 3 // rx.Subscriber subscriber
         0: .line 138
            aload 0
            aload 1
            aload 2
            invokevirtual io.vertx.rxjava.core.http.HttpClient.get:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/rxjava/core/http/HttpClientRequest;
            astore 4 /* req */
        start local 4 // io.vertx.rxjava.core.http.HttpClientRequest req
         1: .line 139
            aload 4 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.toObservable:()Lrx/Observable;
            astore 5 /* resp */
        start local 5 // rx.Observable resp
         2: .line 140
            aload 5 /* resp */
            aload 3 /* subscriber */
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         3: .line 141
            aload 4 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.end:()V
        end local 5 // rx.Observable resp
        end local 4 // io.vertx.rxjava.core.http.HttpClientRequest req
         4: .line 142
            return
        end local 3 // rx.Subscriber subscriber
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     3  subscriber  Lrx/Subscriber<-Lio/vertx/rxjava/core/http/HttpClientResponse;>;
            1    4     4         req  Lio/vertx/rxjava/core/http/HttpClientRequest;
            2    4     5        resp  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;

  private static void lambda$2(io.vertx.rxjava.core.http.HttpClient, int, java.lang.String, java.lang.String, rx.Subscriber);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lrx/Subscriber;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=7, args_size=5
        start local 4 // rx.Subscriber subscriber
         0: .line 150
            aload 0
            iload 1
            aload 2
            aload 3
            invokevirtual io.vertx.rxjava.core.http.HttpClient.get:(ILjava/lang/String;Ljava/lang/String;)Lio/vertx/rxjava/core/http/HttpClientRequest;
            astore 5 /* req */
        start local 5 // io.vertx.rxjava.core.http.HttpClientRequest req
         1: .line 151
            aload 5 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.toObservable:()Lrx/Observable;
            astore 6 /* resp */
        start local 6 // rx.Observable resp
         2: .line 152
            aload 6 /* resp */
            aload 4 /* subscriber */
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         3: .line 153
            aload 5 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.end:()V
        end local 6 // rx.Observable resp
        end local 5 // io.vertx.rxjava.core.http.HttpClientRequest req
         4: .line 154
            return
        end local 4 // rx.Subscriber subscriber
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     4  subscriber  Lrx/Subscriber<-Lio/vertx/rxjava/core/http/HttpClientResponse;>;
            1    4     5         req  Lio/vertx/rxjava/core/http/HttpClientRequest;
            2    4     6        resp  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;

  private static void lambda$3(io.vertx.rxjava.core.http.HttpClient, int, java.lang.String, java.lang.String, io.vertx.rxjava.core.MultiMap, rx.Subscriber);
    descriptor: (Lio/vertx/rxjava/core/http/HttpClient;ILjava/lang/String;Ljava/lang/String;Lio/vertx/rxjava/core/MultiMap;Lrx/Subscriber;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=8, args_size=6
        start local 5 // rx.Subscriber subscriber
         0: .line 173
            aload 0
            iload 1
            aload 2
            aload 3
            invokevirtual io.vertx.rxjava.core.http.HttpClient.get:(ILjava/lang/String;Ljava/lang/String;)Lio/vertx/rxjava/core/http/HttpClientRequest;
            astore 6 /* req */
        start local 6 // io.vertx.rxjava.core.http.HttpClientRequest req
         1: .line 174
            aload 6 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.headers:()Lio/vertx/rxjava/core/MultiMap;
            aload 4
            invokevirtual io.vertx.rxjava.core.MultiMap.addAll:(Lio/vertx/rxjava/core/MultiMap;)Lio/vertx/rxjava/core/MultiMap;
            pop
         2: .line 175
            aload 6 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.toObservable:()Lrx/Observable;
            astore 7 /* resp */
        start local 7 // rx.Observable resp
         3: .line 176
            aload 7 /* resp */
            aload 5 /* subscriber */
            invokevirtual rx.Observable.subscribe:(Lrx/Subscriber;)Lrx/Subscription;
            pop
         4: .line 177
            aload 6 /* req */
            invokevirtual io.vertx.rxjava.core.http.HttpClientRequest.end:()V
        end local 7 // rx.Observable resp
        end local 6 // io.vertx.rxjava.core.http.HttpClientRequest req
         5: .line 178
            return
        end local 5 // rx.Subscriber subscriber
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     5  subscriber  Lrx/Subscriber<-Lio/vertx/rxjava/core/http/HttpClientResponse;>;
            1    5     6         req  Lio/vertx/rxjava/core/http/HttpClientRequest;
            3    5     7        resp  Lrx/Observable<Lio/vertx/rxjava/core/http/HttpClientResponse;>;
}
SourceFile: "RxHelper.java"
NestMembers:
  io.vertx.rxjava.core.RxHelper$1
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract OnSubscribe = rx.Observable$OnSubscribe of rx.Observable
  public abstract Operator = rx.Observable$Operator of rx.Observable
/

io.vertx/ vertx-rx-java/ 3.8.0/ io/vertx/rxjava/core/RxHelper.class
