Class VirtualProcessor.Establishing$

  • All Implemented Interfaces:
    java.io.Serializable, scala.Serializable
    Enclosing class:
    VirtualProcessor<T>

    public static class VirtualProcessor.Establishing$
    extends java.lang.Object
    implements scala.Serializable
    See Also:
    Serialized Form
    • Constructor Detail

      • Establishing$

        public Establishing$()
    • Method Detail

      • $lessinit$greater$default$2

        public boolean $lessinit$greater$default$2()
      • $lessinit$greater$default$3

        public OptionVal<java.lang.Throwable> $lessinit$greater$default$3()
      • apply

        public VirtualProcessor.Establishing apply​(org.reactivestreams.Subscriber<java.lang.Object> subscriber,
                                                   boolean onCompleteBuffered,
                                                   OptionVal<java.lang.Throwable> onErrorBuffered)
      • apply$default$2

        public boolean apply$default$2()
      • apply$default$3

        public OptionVal<java.lang.Throwable> apply$default$3()
      • unapply

        public scala.Option<scala.Tuple3<org.reactivestreams.Subscriber<java.lang.Object>,​java.lang.Object,​OptionVal<java.lang.Throwable>>> unapply​(VirtualProcessor.Establishing x$0)