Searched refs:messagesBuffered (Results 1 – 1 of 1) sorted by relevance
85 private int messagesBuffered; field in MessageFramer128 messagesBuffered++; in writePayload()252 sink.deliverFrame(writeableHeader, false, false, messagesBuffered - 1); in writeBufferChain()253 messagesBuffered = 1; in writeBufferChain()350 sink.deliverFrame(buf, endOfStream, flush, messagesBuffered); in commitToSink()351 messagesBuffered = 0; in commitToSink()