Made API async-compatible, closes #20

Author: Bungeefan

analysis_options.yaml

@@ -6,3 +6,4 @@ include: package:lints/recommended.yaml
 linter:
   rules:
     - prefer_const_constructors
+    - unawaited_futures

lib/src/log_filter.dart

@@ -7,13 +7,13 @@ import 'package:logger/src/logger.dart';
 abstract class LogFilter {
   Level? level;
 
-  void init() {}
+  Future<void> init() async {}
 
   /// Is called every time a new log message is sent and decides if
   /// it will be printed or canceled.
   ///
   /// Returns `true` if the message should be logged.
   bool shouldLog(LogEvent event);
 
-  void destroy() {}
+  Future<void> destroy() async {}
 }

lib/src/log_output.dart

@@ -1,3 +1,5 @@
+import 'dart:async';
+
 import 'package:logger/src/logger.dart';
 
 /// Log output receives a [OutputEvent] from [LogPrinter] and sends it to the
@@ -6,9 +8,9 @@ import 'package:logger/src/logger.dart';
 /// This can be an output stream, a file or a network target. [LogOutput] may
 /// cache multiple log messages.
 abstract class LogOutput {
-  void init() {}
+  Future<void> init() async {}
 
   void output(OutputEvent event);
 
-  void destroy() {}
+  Future<void> destroy() async {}
 }

lib/src/log_printer.dart

@@ -8,11 +8,11 @@ import 'package:logger/src/logger.dart';
 ///
 /// You can implement a `LogPrinter` from scratch or extend [PrettyPrinter].
 abstract class LogPrinter {
-  void init() {}
+  Future<void> init() async {}
 
   /// Is called every time a new [LogEvent] is sent and handles printing or
   /// storing the message.
   List<String> log(LogEvent event);
 
-  void destroy() {}
+  Future<void> destroy() async {}
 }

lib/src/logger.dart

@@ -156,11 +156,11 @@ class Logger {
   }
 
   /// Closes the logger and releases all resources.
-  void close() {
+  Future<void> close() async {
     _active = false;
-    _filter.destroy();
-    _printer.destroy();
-    _output.destroy();
+    await _filter.destroy();
+    await _printer.destroy();
+    await _output.destroy();
   }
 
   /// Register a [LogCallback] which is called for each new [LogEvent].

lib/src/outputs/file_output.dart

@@ -18,7 +18,7 @@ class FileOutput extends LogOutput {
   });
 
   @override
-  void init() {
+  Future<void> init() async {
     _sink = file.openWrite(
       mode: overrideExisting ? FileMode.writeOnly : FileMode.writeOnlyAppend,
       encoding: encoding,
@@ -32,7 +32,7 @@ class FileOutput extends LogOutput {
   }
 
   @override
-  void destroy() async {
+  Future<void> destroy() async {
     await _sink?.flush();
     await _sink?.close();
   }

lib/src/outputs/multi_output.dart

@@ -24,10 +24,8 @@ class MultiOutput extends LogOutput {
   }
 
   @override
-  void init() {
-    for (var o in _outputs) {
-      o.init();
-    }
+  Future<void> init() async {
+    await Future.wait(_outputs.map((e) => e.init()));
   }
 
   @override
@@ -38,9 +36,7 @@ class MultiOutput extends LogOutput {
   }
 
   @override
-  void destroy() {
-    for (var o in _outputs) {
-      o.destroy();
-    }
+  Future<void> destroy() async {
+    await Future.wait(_outputs.map((e) => e.destroy()));
   }
 }

lib/src/outputs/stream_output.dart

@@ -28,7 +28,7 @@ class StreamOutput extends LogOutput {
   }
 
   @override
-  void destroy() {
-    _controller.close();
+  Future<void> destroy() {
+    return _controller.close();
   }
 }

test/logger_test.dart

@@ -186,10 +186,10 @@ void main() {
     expect(printedMessage, 'This is');
   });
 
-  test('Logger.close', () {
+  test('Logger.close', () async {
     var logger = Logger();
     expect(logger.isClosed(), false);
-    logger.close();
+    await logger.close();
     expect(logger.isClosed(), true);
   });
 }