public class StreamToIteratorAdapter<K> extends AbstractStreamToIteratorAdapter<K,K>
Constructor and Description |
---|
StreamToIteratorAdapter(Stream<K> stream) |
Modifier and Type | Method and Description |
---|---|
protected K |
deserialize(K res) |
static <K> Stream<K> |
toStream(org.apache.kafka.common.utils.CloseableIterator<K> iter) |
accept, close, hasNext, next
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining, remove
protected K deserialize(K res)
deserialize
in class AbstractStreamToIteratorAdapter<K,K>
public static <K> Stream<K> toStream(org.apache.kafka.common.utils.CloseableIterator<K> iter)
Copyright © 2020 Red Hat. All rights reserved.