Package 

Class ByteArrayBatchObservable

  • All Implemented Interfaces:
    org.reactivestreams.Publisher 
    
public class ByteArrayBatchObservable
extends Flowable<Array<byte>>

    TODO It may be possible to introduce backpressure here. A helper class for reactive batching of long byte arrays.

    • Method Summary

      Modifier and Type Method Description

      • Methods inherited from class io.reactivex.Flowable

        all, amb, ambArray, ambWith, any, as, blockingFirst, blockingForEach, blockingIterable, blockingLast, blockingLatest, blockingMostRecent, blockingNext, blockingSingle, blockingSubscribe, buffer, buffer, bufferSize, cache, cacheWithInitialCapacity, cast, collect, collectInto, combineLatest, combineLatestDelayError, compose, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEagerDelayError, concatDelayError, concatEager, concatMap, concatMapCompletable, concatMapCompletableDelayError, concatMapDelayError, concatMapEager, concatMapEagerDelayError, concatMapIterable, concatMapMaybe, concatMapMaybeDelayError, concatMapSingle, concatMapSingleDelayError, concatWith, contains, count, create, debounce, defaultIfEmpty, defer, delay, delaySubscription, dematerialize, dematerialize, distinct, distinctUntilChanged, doAfterNext, doAfterTerminate, doFinally, doOnCancel, doOnComplete, doOnEach, doOnError, doOnLifecycle, doOnNext, doOnRequest, doOnSubscribe, doOnTerminate, elementAt, elementAt, elementAtOrError, empty, error, filter, first, firstElement, firstOrError, flatMap, flatMapCompletable, flatMapIterable, flatMapIterable, flatMapMaybe, flatMapSingle, forEach, forEachWhile, fromArray, fromCallable, fromFuture, fromIterable, fromPublisher, generate, groupBy, groupBy, groupJoin, hide, ignoreElements, interval, intervalRange, isEmpty, join, just, last, lastElement, lastOrError, lift, limit, map, materialize, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeWith, never, observeOn, ofType, onBackpressureBuffer, onBackpressureDrop, onBackpressureLatest, onErrorResumeNext, onErrorReturn, onErrorReturnItem, onExceptionResumeNext, onTerminateDetach, parallel, publish, publish, range, rangeLong, rebatchRequests, reduce, reduce, reduceWith, repeat, repeatUntil, repeatWhen, replay, replay, retry, retryUntil, retryWhen, safeSubscribe, sample, scan, scan, scanWith, sequenceEqual, serialize, share, single, singleElement, singleOrError, skip, skipLast, skipUntil, skipWhile, sorted, startWith, startWithArray, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMapCompletable, switchMapCompletableDelayError, switchMapDelayError, switchMapMaybe, switchMapMaybeDelayError, switchMapSingle, switchMapSingleDelayError, switchOnNext, switchOnNextDelayError, take, takeLast, takeUntil, takeWhile, test, throttleFirst, throttleLast, throttleLatest, throttleWithTimeout, timeInterval, timeout, timer, timestamp, to, toFuture, toList, toList, toMap, toMap, toMultimap, toMultimap, toObservable, toSortedList, unsafeCreate, unsubscribeOn, using, window, withLatestFrom, zip, zipArray, zipIterable, zipWith

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ByteArrayBatchObservable

        ByteArrayBatchObservable(Array<byte> bytes, int maxBatchSize)
        Constructor
        Parameters:
        bytes - the byte array that is needed to be split - must not be null
        maxBatchSize - maximum size of an emitted byte[] batch - must be bigger than 0