write method

  1. @override
Future<void> write(
  1. T chunk
)
override

Implementation

@override
Future<void> write(T chunk) async {
  for (final content in splitChunk(chunk, kStreamChunkSize)) {
    await engine.waitForBufferStatusLow(Reliability.reliable);
    final chunk = lk_models.DataStream_Chunk(
      content: content,
      streamId: streamId,
      chunkIndex: Int64(chunkId),
    );
    final chunkPacket = lk_models.DataPacket(
      kind: lk_models.DataPacket_Kind.RELIABLE,
      destinationIdentities: destinationIdentities,
      streamChunk: chunk,
    );
    await engine.sendDataPacket(chunkPacket, reliability: Reliability.reliable);
    chunkId += 1;
  }
}