AsyncPublisherWithBufferAndParamBase<Param extends Object?, Log extends CustomLog> constructor

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

Creates the publisher and its buffered processing queue.

Implementation

AsyncPublisherWithBufferAndParamBase({this.sync = false, this.onError});