Package com.here.platform.data.client.base.http.utils

Class Publishers

java.lang.Object
com.here.platform.data.client.base.http.utils.Publishers
public class Publishers extends Object

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static interface 
    Publishers.GenericSubscription
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    Publishers()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T> org.reactivestreams.Publisher<T>
    fromCloseableIterator(scala.Function0<CloseableIterator<T>> supplier, scala.concurrent.ExecutionContext exec)
     
    static org.reactivestreams.Publisher<ByteBuffer>
    fromFile(Path path, int bufferSize, scala.concurrent.ExecutionContext exec)
     
    static <T> org.reactivestreams.Publisher<T>
    fromItems(scala.collection.immutable.Seq<T> items, scala.concurrent.ExecutionContext exec)
     
    static scala.concurrent.Future<byte[]>
    toByteArray(org.reactivestreams.Publisher<ByteBuffer> publisher)
     
    static InputStream
    toInputStream(org.reactivestreams.Publisher<ByteBuffer> publisher, int itemsBufferSize, scala.concurrent.duration.Duration readTimeout)
     
    static <T> CloseableIterator<T>
    toIterator(org.reactivestreams.Publisher<T> publisher, int bufferSize, scala.concurrent.duration.Duration readTimeout)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • Publishers

      public Publishers()

  • Method Details

    • toIterator

      public static <T> CloseableIterator<T> toIterator(org.reactivestreams.Publisher<T> publisher, int bufferSize, scala.concurrent.duration.Duration readTimeout)

    • toByteArray

      public static scala.concurrent.Future<byte[]> toByteArray(org.reactivestreams.Publisher<ByteBuffer> publisher)

    • toInputStream

      public static InputStream toInputStream(org.reactivestreams.Publisher<ByteBuffer> publisher, int itemsBufferSize, scala.concurrent.duration.Duration readTimeout)

    • fromItems

      public static <T> org.reactivestreams.Publisher<T> fromItems(scala.collection.immutable.Seq<T> items, scala.concurrent.ExecutionContext exec)

    • fromCloseableIterator

      public static <T> org.reactivestreams.Publisher<T> fromCloseableIterator(scala.Function0<CloseableIterator<T>> supplier, scala.concurrent.ExecutionContext exec)

    • fromFile

      public static org.reactivestreams.Publisher<ByteBuffer> fromFile(Path path, int bufferSize, scala.concurrent.ExecutionContext exec)