flush method

@override Future flush([ bool oneway = false ])

Flush any pending data out of a transport buffer. Throws TTransportError if there was an error writing out data.

Implementation

@override
Future flush([bool oneway = false]) {
  final Int8List buff = writeBuffer_.buf;
  final int size = writeBuffer_.len();
  writeBuffer_.reset();

  encodeWord(size, i32buf, 0);
  transport_.write(i32buf, 0, 4);
  transport_.write(buff, 0, size);
  return transport_.flush(oneway);
}