http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-rx/vertx-rx-java2-gen: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.reactivex.impl.ObservableUnmarshaller<T, B> implements io.reactivex.ObservableTransformer<B, T>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.reactivex.impl.ObservableUnmarshaller
  super_class: java.lang.Object
{
  private final java.util.function.Function<B, io.vertx.core.buffer.Buffer> unwrap;
    descriptor: Ljava/util/function/Function;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;

  private final java.lang.Class<T> mappedType;
    descriptor: Ljava/lang/Class;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/lang/Class<TT;>;

  private final com.fasterxml.jackson.core.type.TypeReference<T> mappedTypeRef;
    descriptor: Lcom/fasterxml/jackson/core/type/TypeReference;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;

  private com.fasterxml.jackson.core.ObjectCodec mapper;
    descriptor: Lcom/fasterxml/jackson/core/ObjectCodec;
    flags: (0x0002) ACC_PRIVATE

  public void <init>(java.util.function.Function<B, io.vertx.core.buffer.Buffer>, java.lang.Class<T>);
    descriptor: (Ljava/util/function/Function;Ljava/lang/Class;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // java.util.function.Function unwrap
        start local 2 // java.lang.Class mappedType
         0: .line 31
            aload 0 /* this */
            aload 1 /* unwrap */
            aload 2 /* mappedType */
            aconst_null
            aconst_null
            invokespecial io.vertx.reactivex.impl.ObservableUnmarshaller.<init>:(Ljava/util/function/Function;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;Lcom/fasterxml/jackson/core/ObjectCodec;)V
         1: .line 33
            return
        end local 2 // java.lang.Class mappedType
        end local 1 // java.util.function.Function unwrap
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0    2     1      unwrap  Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;
            0    2     2  mappedType  Ljava/lang/Class<TT;>;
    Signature: (Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;Ljava/lang/Class<TT;>;)V
    MethodParameters:
            Name  Flags
      unwrap      
      mappedType  

  public void <init>(java.util.function.Function<B, io.vertx.core.buffer.Buffer>, com.fasterxml.jackson.core.type.TypeReference<T>);
    descriptor: (Ljava/util/function/Function;Lcom/fasterxml/jackson/core/type/TypeReference;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // java.util.function.Function unwrap
        start local 2 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
         0: .line 36
            aload 0 /* this */
            aload 1 /* unwrap */
            aconst_null
            aload 2 /* mappedTypeRef */
            aconst_null
            invokespecial io.vertx.reactivex.impl.ObservableUnmarshaller.<init>:(Ljava/util/function/Function;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;Lcom/fasterxml/jackson/core/ObjectCodec;)V
         1: .line 37
            return
        end local 2 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
        end local 1 // java.util.function.Function unwrap
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0           this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0    2     1         unwrap  Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;
            0    2     2  mappedTypeRef  Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;
    Signature: (Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;)V
    MethodParameters:
               Name  Flags
      unwrap         
      mappedTypeRef  

  public void <init>(java.util.function.Function<B, io.vertx.core.buffer.Buffer>, java.lang.Class<T>, com.fasterxml.jackson.core.ObjectCodec);
    descriptor: (Ljava/util/function/Function;Ljava/lang/Class;Lcom/fasterxml/jackson/core/ObjectCodec;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // java.util.function.Function unwrap
        start local 2 // java.lang.Class mappedType
        start local 3 // com.fasterxml.jackson.core.ObjectCodec mapper
         0: .line 40
            aload 0 /* this */
            aload 1 /* unwrap */
            aload 2 /* mappedType */
            aconst_null
            aload 3 /* mapper */
            invokespecial io.vertx.reactivex.impl.ObservableUnmarshaller.<init>:(Ljava/util/function/Function;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;Lcom/fasterxml/jackson/core/ObjectCodec;)V
         1: .line 41
            return
        end local 3 // com.fasterxml.jackson.core.ObjectCodec mapper
        end local 2 // java.lang.Class mappedType
        end local 1 // java.util.function.Function unwrap
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0    2     1      unwrap  Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;
            0    2     2  mappedType  Ljava/lang/Class<TT;>;
            0    2     3      mapper  Lcom/fasterxml/jackson/core/ObjectCodec;
    Signature: (Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;Ljava/lang/Class<TT;>;Lcom/fasterxml/jackson/core/ObjectCodec;)V
    MethodParameters:
            Name  Flags
      unwrap      
      mappedType  
      mapper      

  public void <init>(java.util.function.Function<B, io.vertx.core.buffer.Buffer>, com.fasterxml.jackson.core.type.TypeReference<T>, com.fasterxml.jackson.core.ObjectCodec);
    descriptor: (Ljava/util/function/Function;Lcom/fasterxml/jackson/core/type/TypeReference;Lcom/fasterxml/jackson/core/ObjectCodec;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // java.util.function.Function unwrap
        start local 2 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
        start local 3 // com.fasterxml.jackson.core.ObjectCodec mapper
         0: .line 44
            aload 0 /* this */
            aload 1 /* unwrap */
            aconst_null
            aload 2 /* mappedTypeRef */
            aload 3 /* mapper */
            invokespecial io.vertx.reactivex.impl.ObservableUnmarshaller.<init>:(Ljava/util/function/Function;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;Lcom/fasterxml/jackson/core/ObjectCodec;)V
         1: .line 45
            return
        end local 3 // com.fasterxml.jackson.core.ObjectCodec mapper
        end local 2 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
        end local 1 // java.util.function.Function unwrap
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0           this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0    2     1         unwrap  Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;
            0    2     2  mappedTypeRef  Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;
            0    2     3         mapper  Lcom/fasterxml/jackson/core/ObjectCodec;
    Signature: (Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;Lcom/fasterxml/jackson/core/ObjectCodec;)V
    MethodParameters:
               Name  Flags
      unwrap         
      mappedTypeRef  
      mapper         

  private void <init>(java.util.function.Function<B, io.vertx.core.buffer.Buffer>, java.lang.Class<T>, com.fasterxml.jackson.core.type.TypeReference<T>, com.fasterxml.jackson.core.ObjectCodec);
    descriptor: (Ljava/util/function/Function;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;Lcom/fasterxml/jackson/core/ObjectCodec;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=5
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // java.util.function.Function unwrap
        start local 2 // java.lang.Class mappedType
        start local 3 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
        start local 4 // com.fasterxml.jackson.core.ObjectCodec mapper
         0: .line 47
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 48
            aload 0 /* this */
            aload 1 /* unwrap */
            putfield io.vertx.reactivex.impl.ObservableUnmarshaller.unwrap:Ljava/util/function/Function;
         2: .line 49
            aload 0 /* this */
            aload 2 /* mappedType */
            putfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedType:Ljava/lang/Class;
         3: .line 50
            aload 0 /* this */
            aload 3 /* mappedTypeRef */
            putfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedTypeRef:Lcom/fasterxml/jackson/core/type/TypeReference;
         4: .line 51
            aload 0 /* this */
            aload 4 /* mapper */
            putfield io.vertx.reactivex.impl.ObservableUnmarshaller.mapper:Lcom/fasterxml/jackson/core/ObjectCodec;
         5: .line 52
            return
        end local 4 // com.fasterxml.jackson.core.ObjectCodec mapper
        end local 3 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
        end local 2 // java.lang.Class mappedType
        end local 1 // java.util.function.Function unwrap
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    6     0           this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0    6     1         unwrap  Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;
            0    6     2     mappedType  Ljava/lang/Class<TT;>;
            0    6     3  mappedTypeRef  Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;
            0    6     4         mapper  Lcom/fasterxml/jackson/core/ObjectCodec;
    Signature: (Ljava/util/function/Function<TB;Lio/vertx/core/buffer/Buffer;>;Ljava/lang/Class<TT;>;Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;Lcom/fasterxml/jackson/core/ObjectCodec;)V
    MethodParameters:
               Name  Flags
      unwrap         
      mappedType     
      mappedTypeRef  
      mapper         

  public io.reactivex.ObservableSource<T> apply(io.reactivex.Observable<B>);
    descriptor: (Lio/reactivex/Observable;)Lio/reactivex/ObservableSource;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=6, args_size=2
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // io.reactivex.Observable upstream
         0: .line 56
            aload 1 /* upstream */
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.unwrap:Ljava/util/function/Function;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic apply(Ljava/util/function/Function;)Lio/reactivex/functions/Function;
              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;
                  java/util/function/Function.apply(Ljava/lang/Object;)Ljava/lang/Object; (9 itf)
                  (Ljava/lang/Object;)Lio/vertx/core/buffer/Buffer;
            invokevirtual io.reactivex.Observable.map:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
            astore 2 /* unwrapped */
        start local 2 // io.reactivex.Observable unwrapped
         1: .line 57
            aload 2 /* unwrapped */
            invokedynamic call()Ljava/util/concurrent/Callable;
              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;
                  io/vertx/core/buffer/Buffer.buffer()Lio/vertx/core/buffer/Buffer; (6 itf)
                  ()Lio/vertx/core/buffer/Buffer;
            invokedynamic accept()Lio/reactivex/functions/BiConsumer;
              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;)V
                  io/vertx/core/buffer/Buffer.appendBuffer(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/buffer/Buffer; (9 itf)
                  (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/buffer/Buffer;)V
            invokevirtual io.reactivex.Observable.collect:(Ljava/util/concurrent/Callable;Lio/reactivex/functions/BiConsumer;)Lio/reactivex/Single;
            astore 4 /* aggregated */
        start local 4 // io.reactivex.Single aggregated
         2: .line 58
            aload 4 /* aggregated */
            invokevirtual io.reactivex.Single.toMaybe:()Lio/reactivex/Maybe;
            aload 0 /* this */
            invokedynamic apply(Lio/vertx/reactivex/impl/ObservableUnmarshaller;)Lio/reactivex/functions/Function;
              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/reactivex/impl/ObservableUnmarshaller.lambda$3(Lio/vertx/core/buffer/Buffer;)Lio/reactivex/MaybeSource; (7)
                  (Lio/vertx/core/buffer/Buffer;)Lio/reactivex/MaybeSource;
            invokevirtual io.reactivex.Maybe.concatMap:(Lio/reactivex/functions/Function;)Lio/reactivex/Maybe;
            astore 5 /* unmarshalled */
        start local 5 // io.reactivex.Maybe unmarshalled
         3: .line 77
            aload 5 /* unmarshalled */
            invokevirtual io.reactivex.Maybe.toObservable:()Lio/reactivex/Observable;
            areturn
        end local 5 // io.reactivex.Maybe unmarshalled
        end local 4 // io.reactivex.Single aggregated
        end local 2 // io.reactivex.Observable unwrapped
        end local 1 // io.reactivex.Observable upstream
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0    4     1      upstream  Lio/reactivex/Observable<TB;>;
            1    4     2     unwrapped  Lio/reactivex/Observable<Lio/vertx/core/buffer/Buffer;>;
            2    4     4    aggregated  Lio/reactivex/Single<Lio/vertx/core/buffer/Buffer;>;
            3    4     5  unmarshalled  Lio/reactivex/Maybe<TT;>;
    Signature: (Lio/reactivex/Observable<TB;>;)Lio/reactivex/ObservableSource<TT;>;
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
          Name  Flags
      upstream  

  static <T> T getT(io.vertx.core.buffer.Buffer, java.lang.Class<T>, com.fasterxml.jackson.core.type.TypeReference<T>);
    descriptor: (Lio/vertx/core/buffer/Buffer;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;)Ljava/lang/Object;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.core.buffer.Buffer buffer
        start local 1 // java.lang.Class mappedType
        start local 2 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
         0: .line 82
            aload 1 /* mappedType */
            invokestatic java.util.Objects.nonNull:(Ljava/lang/Object;)Z
            ifeq 1
            getstatic io.vertx.core.json.Json.CODEC:Lio/vertx/core/spi/json/JsonCodec;
            aload 0 /* buffer */
            aload 1 /* mappedType */
            invokeinterface io.vertx.core.spi.json.JsonCodec.fromBuffer:(Lio/vertx/core/buffer/Buffer;Ljava/lang/Class;)Ljava/lang/Object;
            goto 2
         1: .line 83
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.core.json.jackson.JacksonFactory.CODEC:Lio/vertx/core/json/jackson/JacksonCodec;
            aload 0 /* buffer */
            aload 2 /* mappedTypeRef */
            invokevirtual io.vertx.core.json.jackson.JacksonCodec.fromBuffer:(Lio/vertx/core/buffer/Buffer;Lcom/fasterxml/jackson/core/type/TypeReference;)Ljava/lang/Object;
         2: .line 82
      StackMap locals:
      StackMap stack: java.lang.Object
            astore 3 /* obj */
        start local 3 // java.lang.Object obj
         3: .line 84
            aload 3 /* obj */
            areturn
        end local 3 // java.lang.Object obj
        end local 2 // com.fasterxml.jackson.core.type.TypeReference mappedTypeRef
        end local 1 // java.lang.Class mappedType
        end local 0 // io.vertx.core.buffer.Buffer buffer
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    4     0         buffer  Lio/vertx/core/buffer/Buffer;
            0    4     1     mappedType  Ljava/lang/Class<TT;>;
            0    4     2  mappedTypeRef  Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;
            3    4     3            obj  TT;
    Signature: <T:Ljava/lang/Object;>(Lio/vertx/core/buffer/Buffer;Ljava/lang/Class<TT;>;Lcom/fasterxml/jackson/core/type/TypeReference<TT;>;)TT;
    MethodParameters:
               Name  Flags
      buffer         
      mappedType     
      mappedTypeRef  

  private io.reactivex.MaybeSource lambda$3(io.vertx.core.buffer.Buffer);
    descriptor: (Lio/vertx/core/buffer/Buffer;)Lio/reactivex/MaybeSource;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
        start local 1 // io.vertx.core.buffer.Buffer buffer
         0: .line 59
            aload 1 /* buffer */
            invokeinterface io.vertx.core.buffer.Buffer.length:()I
            ifle 12
         1: .line 62
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mapper:Lcom/fasterxml/jackson/core/ObjectCodec;
            ifnull 7
         2: .line 63
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mapper:Lcom/fasterxml/jackson/core/ObjectCodec;
            invokevirtual com.fasterxml.jackson.core.ObjectCodec.getFactory:()Lcom/fasterxml/jackson/core/JsonFactory;
            aload 1 /* buffer */
            invokeinterface io.vertx.core.buffer.Buffer.getBytes:()[B
            invokevirtual com.fasterxml.jackson.core.JsonFactory.createParser:([B)Lcom/fasterxml/jackson/core/JsonParser;
            astore 3 /* parser */
        start local 3 // com.fasterxml.jackson.core.JsonParser parser
         3: .line 64
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedType:Ljava/lang/Class;
            invokestatic java.util.Objects.nonNull:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mapper:Lcom/fasterxml/jackson/core/ObjectCodec;
            aload 3 /* parser */
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedType:Ljava/lang/Class;
            invokevirtual com.fasterxml.jackson.core.ObjectCodec.readValue:(Lcom/fasterxml/jackson/core/JsonParser;Ljava/lang/Class;)Ljava/lang/Object;
            goto 5
         4: .line 65
      StackMap locals: io.vertx.reactivex.impl.ObservableUnmarshaller io.vertx.core.buffer.Buffer top com.fasterxml.jackson.core.JsonParser
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mapper:Lcom/fasterxml/jackson/core/ObjectCodec;
            aload 3 /* parser */
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedTypeRef:Lcom/fasterxml/jackson/core/type/TypeReference;
            invokevirtual com.fasterxml.jackson.core.ObjectCodec.readValue:(Lcom/fasterxml/jackson/core/JsonParser;Lcom/fasterxml/jackson/core/type/TypeReference;)Ljava/lang/Object;
         5: .line 64
      StackMap locals:
      StackMap stack: java.lang.Object
            astore 2 /* obj */
        end local 3 // com.fasterxml.jackson.core.JsonParser parser
        start local 2 // java.lang.Object obj
         6: .line 66
            goto 8
        end local 2 // java.lang.Object obj
         7: .line 67
      StackMap locals: io.vertx.reactivex.impl.ObservableUnmarshaller io.vertx.core.buffer.Buffer
      StackMap stack:
            aload 1 /* buffer */
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedType:Ljava/lang/Class;
            aload 0 /* this */
            getfield io.vertx.reactivex.impl.ObservableUnmarshaller.mappedTypeRef:Lcom/fasterxml/jackson/core/type/TypeReference;
            invokestatic io.vertx.reactivex.impl.ObservableUnmarshaller.getT:(Lio/vertx/core/buffer/Buffer;Ljava/lang/Class;Lcom/fasterxml/jackson/core/type/TypeReference;)Ljava/lang/Object;
            astore 2 /* obj */
        start local 2 // java.lang.Object obj
         8: .line 69
      StackMap locals: java.lang.Object
      StackMap stack:
            aload 2 /* obj */
            invokestatic io.reactivex.Maybe.just:(Ljava/lang/Object;)Lio/reactivex/Maybe;
         9: areturn
        end local 2 // java.lang.Object obj
        10: .line 70
      StackMap locals: io.vertx.reactivex.impl.ObservableUnmarshaller io.vertx.core.buffer.Buffer
      StackMap stack: java.lang.Exception
            astore 2 /* e */
        start local 2 // java.lang.Exception e
        11: .line 71
            aload 2 /* e */
            invokestatic io.reactivex.Maybe.error:(Ljava/lang/Throwable;)Lio/reactivex/Maybe;
            areturn
        end local 2 // java.lang.Exception e
        12: .line 74
      StackMap locals:
      StackMap stack:
            invokestatic io.reactivex.Maybe.empty:()Lio/reactivex/Maybe;
            areturn
        end local 1 // io.vertx.core.buffer.Buffer buffer
        end local 0 // io.vertx.reactivex.impl.ObservableUnmarshaller this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   13     0    this  Lio/vertx/reactivex/impl/ObservableUnmarshaller<TT;TB;>;
            0   13     1  buffer  Lio/vertx/core/buffer/Buffer;
            6    7     2     obj  TT;
            8   10     2     obj  TT;
            3    6     3  parser  Lcom/fasterxml/jackson/core/JsonParser;
           11   12     2       e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           1     9      10  Class java.lang.Exception
    Exceptions:
      throws java.lang.Exception
}
Signature: <T:Ljava/lang/Object;B:Ljava/lang/Object;>Ljava/lang/Object;Lio/reactivex/ObservableTransformer<TB;TT;>;
SourceFile: "ObservableUnmarshaller.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles