start method

ChannelMonitor? start(
  1. String channel,
  2. ByteData? message
)

start monitor channel send, if channel in _channelIgnores, return null

Implementation

ChannelMonitor? start(String channel, ByteData? message) {
  if (_channelIgnores.contains(channel)) {
    //ignore
    return null;
  }
  ChannelMonitor channelMonitor = ChannelMonitor();
  final WaitTimeOuter waitTimeOuter = WaitTimeOuter();
  waitTimeOuter.timeOut = timeOut;
  waitTimeOuter.timeOutListener(() {
    end(channelMonitor,
        "time out, more than ${waitTimeOuter.timeOut}seconds no reply!");
  });
  channelMonitor._start(channel, message);
  _channelList[channelMonitor] = waitTimeOuter;
  return channelMonitor;
}