public class io.vertx.reactivex.impl.ObservableReadStream<T, U> extends io.reactivex.Observable<U>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.reactivex.impl.ObservableReadStream
super_class: io.reactivex.Observable
{
private final io.vertx.core.streams.ReadStream<T> stream;
descriptor: Lio/vertx/core/streams/ReadStream;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/streams/ReadStream<TT;>;
private final java.util.function.Function<T, U> f;
descriptor: Ljava/util/function/Function;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/function/Function<TT;TU;>;
private final java.util.concurrent.atomic.AtomicReference<io.reactivex.Observer<? super U>> observer;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/Observer<-TU;>;>;
public void <init>(io.vertx.core.streams.ReadStream<T>, java.util.function.Function<T, U>);
descriptor: (Lio/vertx/core/streams/ReadStream;Ljava/util/function/Function;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial io.reactivex.Observable.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putfield io.vertx.reactivex.impl.ObservableReadStream.observer:Ljava/util/concurrent/atomic/AtomicReference;
2: aload 0
aload 1
putfield io.vertx.reactivex.impl.ObservableReadStream.stream:Lio/vertx/core/streams/ReadStream;
3: aload 0
aload 2
putfield io.vertx.reactivex.impl.ObservableReadStream.f:Ljava/util/function/Function;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/reactivex/impl/ObservableReadStream<TT;TU;>;
0 5 1 stream Lio/vertx/core/streams/ReadStream<TT;>;
0 5 2 f Ljava/util/function/Function<TT;TU;>;
Signature: (Lio/vertx/core/streams/ReadStream<TT;>;Ljava/util/function/Function<TT;TU;>;)V
MethodParameters:
Name Flags
stream
f
protected void subscribeActual(io.reactivex.Observer<? super U>);
descriptor: (Lio/reactivex/Observer;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.reactivex.impl.ObservableReadStream.observer:Ljava/util/concurrent/atomic/AtomicReference;
aload 1
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
1: aload 1
new java.lang.RuntimeException
dup
ldc "Already subscribed"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
2: return
3: StackMap locals:
StackMap stack:
new io.vertx.reactivex.impl.ObservableReadStream$Subscription
dup
aload 0
aload 1
invokespecial io.vertx.reactivex.impl.ObservableReadStream$Subscription.<init>:(Lio/vertx/reactivex/impl/ObservableReadStream;Lio/reactivex/Observer;)V
astore 2
start local 2 4: aload 2
invokevirtual io.vertx.reactivex.impl.ObservableReadStream$Subscription.set:()V
5: aload 1
aload 2
invokeinterface io.reactivex.Observer.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/reactivex/impl/ObservableReadStream<TT;TU;>;
0 7 1 o Lio/reactivex/Observer<-TU;>;
4 7 2 sub Lio/vertx/reactivex/impl/ObservableReadStream<TT;TU;>.Subscription;
Signature: (Lio/reactivex/Observer<-TU;>;)V
MethodParameters:
Name Flags
o
}
Signature: <T:Ljava/lang/Object;U:Ljava/lang/Object;>Lio/reactivex/Observable<TU;>;
SourceFile: "ObservableReadStream.java"
NestMembers:
io.vertx.reactivex.impl.ObservableReadStream$Subscription
InnerClasses:
Subscription = io.vertx.reactivex.impl.ObservableReadStream$Subscription of io.vertx.reactivex.impl.ObservableReadStream