AsyncPublisherBase<Log extends CustomLog> constructor

AsyncPublisherBase<Log extends CustomLog>({
  1. bool sync = false,
  2. void onError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
})

Creates the publisher and starts its processing queue.

Implementation

AsyncPublisherBase({this.sync = false, this.onError})
    : _controller = StreamController<Log>(sync: sync) {
  _listen();
}