send method

  1. @override
Result<(), SendError> send(
  1. T data
)
override

Implementation

@override
Result<(), SendError> send(T data) {
  if (_receiver.isClosed) {
    return const Err(SendError());
  }
  _sink.add(data);
  return const Ok(());
}