Waits for native queue capacity. Await each send or use sink.addStream.
Future<void> send(Object? message) => _sink.send(message);