Simple selection of concurrency mode for transformEvents

[PlugFox]

Simple selection of concurrency mode for transformEvents

[Aqluse]

Predefined modes you mean? Should it be separate package soon as we probably going to use rxdart for it? Or, you going to do a very limited set of these by your own?

[PlugFox]

@Aqluse
Predefined modes.
You always can override transformEvents to make your own.

Also im try create easy template with StreamIterator or something like this.

[PlugFox]

Maybe use StreamIterator for clear management of the order of event processing

[zs-dima]

@PlugFox
Current transformEvents looks good, could be nice to compare with StreamIterator firstly, if it will not complicated some cases:

    final streamEvents = events
        .whereType<StreamEvent>()
        .transform(BlocTransformer(
            (event) => event.events().transform(
                  StreamTransformer<SomeEvent, SomeEvent>.fromHandlers(
                    handleData: (event, sink) => sink.add(event),
                    handleError: (error, stacktrace, sink) => event.onError(error, stacktrace, sink),
                    handleDone: (sink) => event.onDone(),
                  ),
                ),
            maximumConcurrency: 10));

    _callbackEvents = events.whereType<CallbackEvent>();

    final simpleEvents = events.where((event) => event is! StreamEvent && event is! CallbackEvent);

    return MergeStream([
      streamEvents,
      simpleEvents,
    ]).transform(BlocTransformer(next, maximumConcurrency: 10));

it is not clear how StreamIterator could help with similar cases

[PlugFox]

transformEvents is good.

need research how to create simple asyncExpand replacement