Merge pull request #37 from liammclennan/add-stream-flush

Add a `flush` method to the stream

example/example.ts

@@ -13,3 +13,5 @@ logger.info("Hello Seq, from Pino");
 
 const frLogger = logger.child({lang: "fr"});
 frLogger.warn("au reviour");
+
+stream.flush().then((_) => console.log('flushed'));

index.d.ts

@@ -11,7 +11,9 @@ declare namespace PinoSeq {
  onError?: (e: Error) => void;
  }
 
- function createStream(config: PinoSeq.SeqConfig): Writable;
+ function createStream(config: PinoSeq.SeqConfig): Writable & {
+ flush: () => Promise<Boolean>;
+ };
 }
 
 export = PinoSeq;

pinoSeqStream.js

@@ -98,6 +98,11 @@ class PinoSeqStream extends stream.Writable {
  }
  }
 
+ flush() {
+ this.flushBuffer();
+ return this._logger.flush();
+ }
+
  // Force the underlying logger to flush at the time of the call
  // and wait for pending writes to complete
  _final(callback) {