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

Class IteratorAdapter<A>

java.lang.Object
com.here.platform.data.client.utils.IteratorAdapter<A>
All Implemented Interfaces:
scala.collection.IterableOnce<A>, scala.collection.IterableOnceOps<A,scala.collection.Iterator,scala.collection.Iterator<A>>, scala.collection.Iterator<A>
public class IteratorAdapter<A> extends Object implements scala.collection.Iterator<A>

  • Nested Class Summary

    Nested classes/interfaces inherited from interface scala.collection.Iterator

    scala.collection.Iterator.GroupedIterator<B extends Object>, scala.collection.Iterator.SliceIterator<A extends Object>

  • Constructor Summary

    Constructors
    Constructor
    Description
    IteratorAdapter(BlockingQueue<IteratorSinkStage.StreamToAdapterMessage> sharedBuffer, scala.Function1<IteratorSinkStage.AdapterToStageMessage,scala.runtime.BoxedUnit> sendToStage, scala.concurrent.duration.FiniteDuration readTimeout)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    scala.Option<A>
    detachedChunk()
     
    boolean
    hasNext()
     
    boolean
    isInitialized()
     
    boolean
    isStageAlive()
     
    A
    next()
     
    IOException
    subscriberClosedException()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface scala.collection.IterableOnce

    knownSize, stepper

    Methods inherited from interface scala.collection.IterableOnceOps

    $colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToArray, copyToBuffer, corresponds, count, exists, find, fold, foldLeft, foldRight, forall, foreach, isTraversableAgain, max, maxBy, maxByOption, maxOption, min, minBy, minByOption, minOption, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, size, splitAt, sum, to, toArray, toBuffer, toIndexedSeq, toIterator, toList, toMap, toSeq, toSet, toStream, toVector

    Methods inherited from interface scala.collection.Iterator

    $plus$plus, buffered, collect, concat, contains, distinct, distinctBy, drop, dropWhile, duplicate, filter, filterImpl, filterNot, flatMap, flatten, grouped, hasDefiniteSize, indexOf, indexOf, indexWhere, indexWhere$default$2, isEmpty, iterator, length, map, nextOption, padTo, partition, patch, sameElements, scanLeft, scanRight, seq, slice, sliceIterator, sliding, sliding$default$2, span, take, takeWhile, tapEach, toString, withFilter, zip, zipAll, zipWithIndex

  • Constructor Details

  • Method Details

    • close

      public void close()

    • detachedChunk

      public scala.Option<A> detachedChunk()

    • hasNext

      public boolean hasNext()
      Specified by:
      hasNext in interface scala.collection.Iterator<A>

    • isInitialized

      public boolean isInitialized()

    • isStageAlive

      public boolean isStageAlive()

    • next

      public A next()
      Specified by:
      next in interface scala.collection.Iterator<A>

    • subscriberClosedException

      public IOException subscriberClosedException()