Package org.apache.tinkerpop.gremlin.driver.stream

Class GraphBinaryStreamResponseReader

java.lang.Object

org.apache.tinkerpop.gremlin.driver.stream.GraphBinaryStreamResponseReader

All Implemented Interfaces:

Runnable

public class GraphBinaryStreamResponseReader
extends Object
implements Runnable

Performs pull-based streaming deserialization of a GraphBinary v4 response from an InputStreamBuffer. Reads one item at a time using the GraphBinaryReader and TypeSerializer infrastructure, pushing each result to the ResultSet as it is deserialized.

Wire format: [version_byte][bulked_flag_byte][items...][EndOfStream marker][status_code][message][exception]

Constructor Summary

Constructors

Constructor	Description
GraphBinaryStreamResponseReader(Buffer buffer, GraphBinaryReader reader, ResultSet resultSet, AtomicReference<ResultSet> pendingResultSet)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

GraphBinaryStreamResponseReader

public GraphBinaryStreamResponseReader(Buffer buffer,
 GraphBinaryReader reader,
 ResultSet resultSet,
 AtomicReference<ResultSet> pendingResultSet)

Method Details

run

public void run()

Specified by:

run in interface Runnable