Result<(), SendError> sendError(Object error) { if (_receiver.isClosed) { return const Err(SendError()); } _sink.addError(error); return const Ok(()); }