@override void fire(Object message) { if (closed) { throw ClosedException(); } sendPort.send(_FireMessage(message)); }