public class StreamedSiblingsCollection extends CollectionWrapper<RiakObject>
Constructor and Description |
---|
StreamedSiblingsCollection(RiakClient riak,
String bucket,
String key,
StreamedMultipart multipart) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
cacheNext()
Tries to read and cache another part of the multipart/mixed stream.
|
protected void |
closeBackend()
Close the backend so no more objects can be read from it (getNext()
should only return null afterwards).
|
add, addAll, cache, clear, contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
equals, hashCode
public StreamedSiblingsCollection(RiakClient riak, String bucket, String key, StreamedMultipart multipart)
protected boolean cacheNext()
cacheNext
in class CollectionWrapper<RiakObject>
RiakIORuntimeException
- If an error occurs during communication with the Riak server.protected void closeBackend()
CollectionWrapper
closeBackend
in class CollectionWrapper<RiakObject>
Copyright © 2014. All Rights Reserved.