(C)FluxJust
- T value
+ subscribe(Subscriber s)
Has a
(C)FluxSource(Decorator)
+ Publisher source
+ static FluxSource wrap(Publish source)+ subscribe(Subscriber s)
(C)FluxAwaitOnSubscribe
(I)Processor
由Publisher生成传递给Subscriber的onSubscribe方法。只有当一个Subscriber订阅了一个Publisher时才会生成，贯穿整个订阅的声明周期，一直到结束状态。所以它的生成其实是在Publisher的subscribe方法中，之后转交给Subscriber，是两者之间的桥梁。
(C)WeakScalarSubscription
+ T value+ Subscriber actual
+ request(long n) + cancel()
(I)Subscriber
+ onSubscribe(Subscription s)+ onNext(T t)+ onError(Throwable t)+ onComplete()
(I)Subscription
(C)Flux
+ 各种操作符+ 各种静态方法
(C)PostOnSubscribeSubscriber
+ Subscriber actual(被装饰者)+ Subscription s(被装饰者)+ volatile long requested
+ onSubscribe(Subscription s)+ onNext(T t)+ onError(Throwable t)+ onComplete()+ request(long n) + cancel()
(I)Publisher
(C)LambdaSubscriber
+ Consumer consumer+ Consumer errorConsumer+ Runnable completeConsumer+ Runnable subscriptionConsumer+ Subscription subscription
