io.vertx/vertx-core/4.0.0 : io/vertx/core/shareddata/impl/LocalAsyncMapImpl.class

LocalAsyncMapImpl
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-core: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
public class io.vertx.core.shareddata.impl.LocalAsyncMapImpl<K, V> implements io.vertx.core.shareddata.AsyncMap<K, V>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.core.shareddata.impl.LocalAsyncMapImpl
  super_class: java.lang.Object
{
  private final io.vertx.core.impl.VertxInternal vertx;
    descriptor: Lio/vertx/core/impl/VertxInternal;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.ConcurrentMap<K, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder<V>> map;
    descriptor: Ljava/util/concurrent/ConcurrentMap;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/ConcurrentMap<TK;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;>;

  public void <init>(io.vertx.core.impl.VertxInternal);
    descriptor: (Lio/vertx/core/impl/VertxInternal;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // io.vertx.core.impl.VertxInternal vertx
         0: .line 40
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 41
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
         2: .line 42
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
         3: .line 43
            return
        end local 1 // io.vertx.core.impl.VertxInternal vertx
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    4     1  vertx  Lio/vertx/core/impl/VertxInternal;
    MethodParameters:
       Name  Flags
      vertx  

  public io.vertx.core.Future<V> get(K);
    descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
         0: .line 47
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 2 /* ctx */
        start local 2 // io.vertx.core.impl.ContextInternal ctx
         1: .line 48
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 3 /* h */
        start local 3 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
         2: .line 49
            aload 3 /* h */
            ifnull 4
            aload 3 /* h */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.hasNotExpired:()Z
            ifeq 4
         3: .line 50
            aload 2 /* ctx */
            aload 3 /* h */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
         4: .line 52
      StackMap locals: io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack:
            aload 2 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 3 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
        end local 2 // io.vertx.core.impl.ContextInternal ctx
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    5     1     k  TK;
            1    5     2   ctx  Lio/vertx/core/impl/ContextInternal;
            2    5     3     h  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;)Lio/vertx/core/Future<TV;>;
    MethodParameters:
      Name  Flags
      k     

  public io.vertx.core.Future<java.lang.Void> put(K, V);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object v
         0: .line 58
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 3 /* ctx */
        start local 3 // io.vertx.core.impl.ContextInternal ctx
         1: .line 59
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            dup
            aload 2 /* v */
            invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
            invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 4 /* previous */
        start local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
         2: .line 60
            aload 4 /* previous */
            ifnull 4
            aload 4 /* previous */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 4
         3: .line 61
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 4 /* previous */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         4: .line 63
      StackMap locals: io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack:
            aload 3 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
        end local 3 // io.vertx.core.impl.ContextInternal ctx
        end local 2 // java.lang.Object v
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    5     1         k  TK;
            0    5     2         v  TV;
            1    5     3       ctx  Lio/vertx/core/impl/ContextInternal;
            2    5     4  previous  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;TV;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      k     
      v     

  public io.vertx.core.Future<V> putIfAbsent(K, V);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object v
         0: .line 68
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 3 /* ctx */
        start local 3 // io.vertx.core.impl.ContextInternal ctx
         1: .line 69
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            dup
            aload 2 /* v */
            invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
            invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 4 /* h */
        start local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
         2: .line 70
            aload 3 /* ctx */
            aload 4 /* h */
            ifnonnull 3
            aconst_null
            goto 4
      StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack: io.vertx.core.impl.ContextInternal
         3: aload 4 /* h */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
      StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack: io.vertx.core.impl.ContextInternal java.lang.Object
         4: invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
        end local 3 // io.vertx.core.impl.ContextInternal ctx
        end local 2 // java.lang.Object v
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    5     1     k  TK;
            0    5     2     v  TV;
            1    5     3   ctx  Lio/vertx/core/impl/ContextInternal;
            2    5     4     h  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;TV;)Lio/vertx/core/Future<TV;>;
    MethodParameters:
      Name  Flags
      k     
      v     

  public io.vertx.core.Future<java.lang.Void> put(K, V, long);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;J)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=11, locals=11, args_size=4
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object v
        start local 3 // long ttl
         0: .line 75
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 5 /* ctx */
        start local 5 // io.vertx.core.impl.ContextInternal ctx
         1: .line 76
            invokestatic java.lang.System.nanoTime:()J
            lstore 6 /* timestamp */
        start local 6 // long timestamp
         2: .line 77
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            lload 3 /* ttl */
            aload 0 /* this */
            aload 1 /* k */
            invokedynamic handle(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;)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
                  io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$0(Ljava/lang/Object;Ljava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.impl.VertxInternal.setTimer:(JLio/vertx/core/Handler;)J
            lstore 8 /* timerId */
        start local 8 // long timerId
         3: .line 78
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            dup
            aload 2 /* v */
            lload 8 /* timerId */
            lload 3 /* ttl */
            lload 6 /* timestamp */
            invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;JJJ)V
            invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 10 /* previous */
        start local 10 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
         4: .line 79
            aload 10 /* previous */
            ifnull 6
            aload 10 /* previous */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 6
         5: .line 80
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 10 /* previous */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         6: .line 82
      StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object long io.vertx.core.impl.ContextInternal long long io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack:
            aload 5 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 10 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
        end local 8 // long timerId
        end local 6 // long timestamp
        end local 5 // io.vertx.core.impl.ContextInternal ctx
        end local 3 // long ttl
        end local 2 // java.lang.Object v
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    7     1          k  TK;
            0    7     2          v  TV;
            0    7     3        ttl  J
            1    7     5        ctx  Lio/vertx/core/impl/ContextInternal;
            2    7     6  timestamp  J
            3    7     8    timerId  J
            4    7    10   previous  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;TV;J)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
      Name  Flags
      k     
      v     
      ttl   

  private void removeIfExpired();
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
         0: .line 86
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            invokedynamic apply()Ljava/util/function/BiFunction;
              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;)Ljava/lang/Object;
                  io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$1(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder; (6)
                  (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
            invokeinterface java.util.concurrent.ConcurrentMap.computeIfPresent:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
            pop
         1: .line 87
            return
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    2     1     k  TK;
    Signature: (TK;)V
    MethodParameters:
      Name  Flags
      k     

  public io.vertx.core.Future<V> putIfAbsent(K, V, long);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;J)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=11, locals=11, args_size=4
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object v
        start local 3 // long ttl
         0: .line 91
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 5 /* ctx */
        start local 5 // io.vertx.core.impl.ContextInternal ctx
         1: .line 92
            invokestatic java.lang.System.nanoTime:()J
            lstore 6 /* timestamp */
        start local 6 // long timestamp
         2: .line 93
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            lload 3 /* ttl */
            aload 0 /* this */
            aload 1 /* k */
            invokedynamic handle(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;)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
                  io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$2(Ljava/lang/Object;Ljava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.impl.VertxInternal.setTimer:(JLio/vertx/core/Handler;)J
            lstore 8 /* timerId */
        start local 8 // long timerId
         3: .line 94
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            dup
            aload 2 /* v */
            lload 8 /* timerId */
            lload 3 /* ttl */
            lload 6 /* timestamp */
            invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;JJJ)V
            invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 10 /* existing */
        start local 10 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder existing
         4: .line 95
            aload 10 /* existing */
            ifnull 8
         5: .line 96
            aload 10 /* existing */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 7
         6: .line 97
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            lload 8 /* timerId */
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         7: .line 99
      StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object long io.vertx.core.impl.ContextInternal long long io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack:
            aload 5 /* ctx */
            aload 10 /* existing */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
         8: .line 101
      StackMap locals:
      StackMap stack:
            aload 5 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 10 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder existing
        end local 8 // long timerId
        end local 6 // long timestamp
        end local 5 // io.vertx.core.impl.ContextInternal ctx
        end local 3 // long ttl
        end local 2 // java.lang.Object v
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    9     0       this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    9     1          k  TK;
            0    9     2          v  TV;
            0    9     3        ttl  J
            1    9     5        ctx  Lio/vertx/core/impl/ContextInternal;
            2    9     6  timestamp  J
            3    9     8    timerId  J
            4    9    10   existing  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;TV;J)Lio/vertx/core/Future<TV;>;
    MethodParameters:
      Name  Flags
      k     
      v     
      ttl   

  public io.vertx.core.Future<java.lang.Boolean> removeIfPresent(K, V);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object v
         0: .line 107
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 3 /* ctx */
        start local 3 // io.vertx.core.impl.ContextInternal ctx
         1: .line 108
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
            astore 4 /* result */
        start local 4 // java.util.concurrent.atomic.AtomicBoolean result
         2: .line 109
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            aload 0 /* this */
            aload 2 /* v */
            aload 4 /* result */
            invokedynamic apply(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicBoolean;)Ljava/util/function/BiFunction;
              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;)Ljava/lang/Object;
                  io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$3(Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicBoolean;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder; (7)
                  (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
            invokeinterface java.util.concurrent.ConcurrentMap.computeIfPresent:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
            pop
         3: .line 119
            aload 3 /* ctx */
            aload 4 /* result */
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 4 // java.util.concurrent.atomic.AtomicBoolean result
        end local 3 // io.vertx.core.impl.ContextInternal ctx
        end local 2 // java.lang.Object v
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    4     1       k  TK;
            0    4     2       v  TV;
            1    4     3     ctx  Lio/vertx/core/impl/ContextInternal;
            2    4     4  result  Ljava/util/concurrent/atomic/AtomicBoolean;
    Signature: (TK;TV;)Lio/vertx/core/Future<Ljava/lang/Boolean;>;
    MethodParameters:
      Name  Flags
      k     
      v     

  public io.vertx.core.Future<V> replace(K, V);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object v
         0: .line 124
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 3 /* ctx */
        start local 3 // io.vertx.core.impl.ContextInternal ctx
         1: .line 125
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            dup
            aload 2 /* v */
            invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
            invokeinterface java.util.concurrent.ConcurrentMap.replace:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 4 /* previous */
        start local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
         2: .line 126
            aload 4 /* previous */
            ifnull 6
         3: .line 127
            aload 4 /* previous */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 5
         4: .line 128
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 4 /* previous */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         5: .line 130
      StackMap locals: io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack:
            aload 3 /* ctx */
            aload 4 /* previous */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
         6: .line 132
      StackMap locals:
      StackMap stack:
            aload 3 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
        end local 3 // io.vertx.core.impl.ContextInternal ctx
        end local 2 // java.lang.Object v
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    7     1         k  TK;
            0    7     2         v  TV;
            1    7     3       ctx  Lio/vertx/core/impl/ContextInternal;
            2    7     4  previous  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;TV;)Lio/vertx/core/Future<TV;>;
    MethodParameters:
      Name  Flags
      k     
      v     

  public io.vertx.core.Future<java.lang.Boolean> replaceIfPresent(K, V, V);
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=4
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
        start local 2 // java.lang.Object oldValue
        start local 3 // java.lang.Object newValue
         0: .line 137
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 4 /* ctx */
        start local 4 // io.vertx.core.impl.ContextInternal ctx
         1: .line 138
            new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            dup
            aload 3 /* newValue */
            invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
            astore 5 /* h */
        start local 5 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
         2: .line 139
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            aload 0 /* this */
            aload 2 /* oldValue */
            aload 5 /* h */
            invokedynamic apply(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/util/function/BiFunction;
              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;)Ljava/lang/Object;
                  io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$4(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder; (7)
                  (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
            invokeinterface java.util.concurrent.ConcurrentMap.computeIfPresent:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 6 /* result */
        start local 6 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder result
         3: .line 148
            aload 4 /* ctx */
            aload 5 /* h */
            aload 6 /* result */
            if_acmpne 4
            iconst_1
            goto 5
      StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object java.lang.Object io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack: io.vertx.core.impl.ContextInternal
         4: iconst_0
      StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object java.lang.Object io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack: io.vertx.core.impl.ContextInternal int
         5: invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 6 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder result
        end local 5 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
        end local 4 // io.vertx.core.impl.ContextInternal ctx
        end local 3 // java.lang.Object newValue
        end local 2 // java.lang.Object oldValue
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    6     0      this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    6     1         k  TK;
            0    6     2  oldValue  TV;
            0    6     3  newValue  TV;
            1    6     4       ctx  Lio/vertx/core/impl/ContextInternal;
            2    6     5         h  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
            3    6     6    result  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;TV;TV;)Lio/vertx/core/Future<Ljava/lang/Boolean;>;
    MethodParameters:
          Name  Flags
      k         
      oldValue  
      newValue  

  public io.vertx.core.Future<java.lang.Void> clear();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
         0: .line 153
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 1 /* ctx */
        start local 1 // io.vertx.core.impl.ContextInternal ctx
         1: .line 154
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            invokeinterface java.util.concurrent.ConcurrentMap.clear:()V
         2: .line 155
            aload 1 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.impl.ContextInternal ctx
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            1    3     1   ctx  Lio/vertx/core/impl/ContextInternal;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public io.vertx.core.Future<java.lang.Integer> size();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
         0: .line 160
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 1 /* ctx */
        start local 1 // io.vertx.core.impl.ContextInternal ctx
         1: .line 161
            aload 1 /* ctx */
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            invokeinterface java.util.concurrent.ConcurrentMap.size:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.impl.ContextInternal ctx
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            1    2     1   ctx  Lio/vertx/core/impl/ContextInternal;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Integer;>;

  public io.vertx.core.Future<java.util.Set<K>> keys();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
         0: .line 166
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 1 /* ctx */
        start local 1 // io.vertx.core.impl.ContextInternal ctx
         1: .line 167
            aload 1 /* ctx */
            new java.util.HashSet
            dup
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            invokeinterface java.util.concurrent.ConcurrentMap.keySet:()Ljava/util/Set;
            invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.impl.ContextInternal ctx
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            1    2     1   ctx  Lio/vertx/core/impl/ContextInternal;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Set<TK;>;>;

  public io.vertx.core.Future<java.util.List<V>> values();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
         0: .line 172
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 1 /* ctx */
        start local 1 // io.vertx.core.impl.ContextInternal ctx
         1: .line 173
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
         2: .line 174
            invokedynamic test()Ljava/util/function/Predicate;
              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;)Z
                  io/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder.hasNotExpired()Z (5)
                  (Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
         3: .line 175
            invokedynamic apply()Ljava/util/function/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/core/shareddata/impl/LocalAsyncMapImpl.lambda$6(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/lang/Object; (6)
                  (Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/lang/Object;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         4: .line 176
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.List
         5: .line 173
            astore 2 /* result */
        start local 2 // java.util.List result
         6: .line 177
            aload 1 /* ctx */
            aload 2 /* result */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 2 // java.util.List result
        end local 1 // io.vertx.core.impl.ContextInternal ctx
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            1    7     1     ctx  Lio/vertx/core/impl/ContextInternal;
            6    7     2  result  Ljava/util/List<TV;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/List<TV;>;>;

  public io.vertx.core.Future<java.util.Map<K, V>> entries();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
         0: .line 182
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 1 /* ctx */
        start local 1 // io.vertx.core.impl.ContextInternal ctx
         1: .line 183
            new java.util.HashMap
            dup
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            invokeinterface java.util.concurrent.ConcurrentMap.size:()I
            invokespecial java.util.HashMap.<init>:(I)V
            astore 2 /* result */
        start local 2 // java.util.Map result
         2: .line 184
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 2 /* result */
            invokedynamic accept(Ljava/util/Map;)Ljava/util/function/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/shareddata/impl/LocalAsyncMapImpl.lambda$7(Ljava/util/Map;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)V (6)
                  (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)V
            invokeinterface java.util.concurrent.ConcurrentMap.forEach:(Ljava/util/function/BiConsumer;)V
         3: .line 189
            aload 1 /* ctx */
            aload 2 /* result */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 2 // java.util.Map result
        end local 1 // io.vertx.core.impl.ContextInternal ctx
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            1    4     1     ctx  Lio/vertx/core/impl/ContextInternal;
            2    4     2  result  Ljava/util/Map<TK;TV;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Map<TK;TV;>;>;

  public io.vertx.core.Future<V> remove(K);
    descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 1 // java.lang.Object k
         0: .line 194
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 2 /* ctx */
        start local 2 // io.vertx.core.impl.ContextInternal ctx
         1: .line 195
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
            aload 1 /* k */
            invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
            astore 3 /* previous */
        start local 3 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
         2: .line 196
            aload 3 /* previous */
            ifnull 6
         3: .line 197
            aload 3 /* previous */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 5
         4: .line 198
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 3 /* previous */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         5: .line 200
      StackMap locals: io.vertx.core.impl.ContextInternal io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
      StackMap stack:
            aload 2 /* ctx */
            aload 3 /* previous */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
         6: .line 202
      StackMap locals:
      StackMap stack:
            aload 2 /* ctx */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 3 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder previous
        end local 2 // io.vertx.core.impl.ContextInternal ctx
        end local 1 // java.lang.Object k
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0      this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    7     1         k  TK;
            1    7     2       ctx  Lio/vertx/core/impl/ContextInternal;
            2    7     3  previous  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
    Signature: (TK;)Lio/vertx/core/Future<TV;>;
    MethodParameters:
      Name  Flags
      k     

  private void lambda$0(java.lang.Object, java.lang.Long);
    descriptor: (Ljava/lang/Object;Ljava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 2 // java.lang.Long l
         0: .line 77
            aload 0 /* this */
            aload 1
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl.removeIfExpired:(Ljava/lang/Object;)V
            return
        end local 2 // java.lang.Long l
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    1     2     l  Ljava/lang/Long;

  private static io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder lambda$1(java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
    descriptor: (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // java.lang.Object key
        start local 1 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
         0: .line 86
            aload 1 /* holder */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.hasNotExpired:()Z
            ifeq 1
            aload 1 /* holder */
            goto 2
      StackMap locals:
      StackMap stack:
         1: aconst_null
      StackMap locals:
      StackMap stack: io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
         2: areturn
        end local 1 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
        end local 0 // java.lang.Object key
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0     key  TK;
            0    3     1  holder  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;

  private void lambda$2(java.lang.Object, java.lang.Long);
    descriptor: (Ljava/lang/Object;Ljava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 2 // java.lang.Long l
         0: .line 93
            aload 0 /* this */
            aload 1
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl.removeIfExpired:(Ljava/lang/Object;)V
            return
        end local 2 // java.lang.Long l
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    1     2     l  Ljava/lang/Long;

  private io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder lambda$3(java.lang.Object, java.util.concurrent.atomic.AtomicBoolean, java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
    descriptor: (Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicBoolean;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=5
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 3 // java.lang.Object key
        start local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
         0: .line 110
            aload 4 /* holder */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            aload 1
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 5
         1: .line 111
            aload 2
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            pop
         2: .line 112
            aload 4 /* holder */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 4
         3: .line 113
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 4 /* holder */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         4: .line 115
      StackMap locals:
      StackMap stack:
            aconst_null
            areturn
         5: .line 117
      StackMap locals:
      StackMap stack:
            aload 4 /* holder */
            areturn
        end local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
        end local 3 // java.lang.Object key
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0    this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    6     3     key  TK;
            0    6     4  holder  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;

  private io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder lambda$4(java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder, java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
    descriptor: (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=5
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
        start local 3 // java.lang.Object key
        start local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
         0: .line 140
            aload 4 /* holder */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            aload 1
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
         1: .line 141
            aload 4 /* holder */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
            ifeq 3
         2: .line 142
            aload 0 /* this */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            aload 4 /* holder */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
            invokeinterface io.vertx.core.impl.VertxInternal.cancelTimer:(J)Z
            pop
         3: .line 144
      StackMap locals:
      StackMap stack:
            aload 2
            areturn
         4: .line 146
      StackMap locals:
      StackMap stack:
            aload 4 /* holder */
            areturn
        end local 4 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
        end local 3 // java.lang.Object key
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
            0    5     3     key  TK;
            0    5     4  holder  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;

  private static java.lang.Object lambda$6(io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
    descriptor: (Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
         0: .line 175
            aload 0 /* h */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            areturn
        end local 0 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder h
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     h  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;

  private static void lambda$7(java.util.Map, java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
    descriptor: (Ljava/util/Map;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 1 // java.lang.Object key
        start local 2 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
         0: .line 185
            aload 2 /* holder */
            invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.hasNotExpired:()Z
            ifeq 2
         1: .line 186
            aload 0
            aload 1 /* key */
            aload 2 /* holder */
            getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 188
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder holder
        end local 1 // java.lang.Object key
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     1     key  TK;
            0    3     2  holder  Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;
SourceFile: "LocalAsyncMapImpl.java"
NestMembers:
  io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
InnerClasses:
  private Holder = io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder of io.vertx.core.shareddata.impl.LocalAsyncMapImpl
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
/

io.vertx/ vertx-core/ 4.0.0/ io/vertx/core/shareddata/impl/LocalAsyncMapImpl.class
