public abstract class AbstractStreamToIteratorAdapter<I,O> extends Object implements org.apache.kafka.common.utils.CloseableIterator<O>, Consumer<I>
Constructor and Description |
---|
AbstractStreamToIteratorAdapter(Stream<I> stream) |
Modifier and Type | Method and Description |
---|---|
void |
accept(I kv) |
void |
close() |
protected abstract O |
deserialize(I res) |
boolean |
hasNext() |
O |
next() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining, remove
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.kafka.common.utils.CloseableIterator<O>
Copyright © 2020 Red Hat. All rights reserved.