Class SegmentPublisherWrapper<Type>

    • Method Detail

      • wrap

        public static <Type> SegmentPublisherWrapper<Type> wrap​(io.reactivex.rxjava3.flowables.GroupedFlowable<Integer,​? extends Type> groupedFlowable)
      • subscribe

        public void subscribe​(org.reactivestreams.Subscriber<? super Type> s)
        Specified by:
        subscribe in interface org.reactivestreams.Publisher<Type>