Searched defs:streamChunkId (Results 1 – 6 of 6) sorted by relevance
27 public final StreamChunkId streamChunkId; field in ChunkFetchFailure30 public ChunkFetchFailure(StreamChunkId streamChunkId, String errorString) { in ChunkFetchFailure()50 StreamChunkId streamChunkId = StreamChunkId.decode(buf); in decode() local
34 public final StreamChunkId streamChunkId; field in ChunkFetchSuccess36 public ChunkFetchSuccess(StreamChunkId streamChunkId, ManagedBuffer buffer) { in ChunkFetchSuccess()62 StreamChunkId streamChunkId = StreamChunkId.decode(buf); in decode() local
28 public final StreamChunkId streamChunkId; field in ChunkFetchRequest30 public ChunkFetchRequest(StreamChunkId streamChunkId) { in ChunkFetchRequest()
49 StreamChunkId streamChunkId = new StreamChunkId(1, 0); in handleSuccessfulFetch() local63 StreamChunkId streamChunkId = new StreamChunkId(1, 0); in handleFailedFetch() local
73 public void addFetchRequest(StreamChunkId streamChunkId, ChunkReceivedCallback callback) { in addFetchRequest()78 public void removeFetchRequest(StreamChunkId streamChunkId) { in removeFetchRequest()
143 final StreamChunkId streamChunkId = new StreamChunkId(streamId, chunkIndex); in fetchChunk() local