stream property

Stream<CoapRespondEvent> stream

Response stream

Implementation

Stream<CoapRespondEvent> get stream => _request.eventBus!
    .on<CoapRespondEvent>()
    .where((final e) => e.resp.token!.equals(_request.token!))
    .takeWhile((final _) => !_request.isTimedOut && !_request.isCancelled);