send method

void send(
  1. TOutgoing msg
)

Implementation

void send(TOutgoing msg) {
  channel.sink.add(serializer(msg));
}