Small non-breaking improvements

lib/contracts.dart

@@ -1,5 +1,5 @@
 /// Contracts for both Events/Requests
-library contracts;
+library;
 
 export 'src/event/event.dart';
 export 'src/request/request.dart' hide Request;

lib/event_manager.dart

@@ -1,5 +1,5 @@
 /// A predictable event manager library for domain events.
-library event_manager;
+library;
 
 export 'src/event/event.dart';
 export 'src/event/event_manager.dart';

lib/mediator.dart

@@ -1,5 +1,5 @@
-// A predictable Mediator library.
-library mediator;
+/// A predictable Mediator library.
+library;
 
 export 'event_manager.dart';
 export 'request_manager.dart';

lib/reactive.dart

@@ -1,5 +1,5 @@
 /// Reactive extensions for events
-library reactive;
+library;
 
 export 'src/event/reactive/combine_latest.dart';
 export 'src/event/reactive/merge.dart';

lib/request_manager.dart

@@ -1,5 +1,5 @@
 /// A predictable CQRS manager.
-library request_manager;
+library;
 
 export 'src/request/request.dart';
 export 'src/request/request_manager.dart';

lib/src/event/handler/event_handler_store.dart

@@ -44,11 +44,6 @@ class EventHandlerStore {
   }
 
   Set<EventHandler> _getHandlersFor(Type eventType) {
-    final handlers = _handlers.putIfAbsent(
-      eventType,
-      () => <EventHandler>{},
-    );
-
-    return handlers;
+    return _handlers[eventType] ?? const <EventHandler>{};
   }
 }

lib/src/event/subscription_builder/distinct_builder.dart

@@ -30,7 +30,7 @@ class _DistinctEventHandler<T> implements EventHandler<T> {
   FutureOr<void> handle(T event) {
     if (identical(_previous, sentinel)) {
       _previous = event;
-      // Skip first event.
+      // Always emit first event.
       return parent.handle(event);
     }
 

lib/src/request/pipeline/pipeline_configurator.dart

@@ -1,4 +1,5 @@
-import 'package:dart_mediator/request_manager.dart';
+import 'package:dart_mediator/src/request/pipeline/pipeline_behavior.dart';
+import 'package:dart_mediator/src/request/request.dart';
 
 abstract interface class PipelineConfigurator {
   /// Registers the [behavior].

lib/src/request/request_manager.dart

@@ -67,7 +67,7 @@ class RequestManager {
 
     FutureOr<TResponse> handle() => handler.handle(request);
 
-    final RequestHandlerDelegate executionPlan = pipelines.fold(
+    final RequestHandlerDelegate<TResponse> executionPlan = pipelines.fold(
       handle,
       (next, pipeline) {
         FutureOr<TResponse> pipelineHandler() async {