extend options

altera2015 · Sep 3, 2023 · b96fc57 · b96fc57
1 parent c8789cc
commit b96fc57
Showing 1 changed file with 15 additions and 6 deletions.
diff --git a/lib/transaction.dart b/lib/transaction.dart
@@ -40,8 +40,9 @@ class Transaction<T> {
   /// ```dart
   /// var c = Transaction.terminated(p.inputStream, Uint8List.fromList([13, 10]));
   /// ```
-  static Transaction<Uint8List> terminated(Stream<Uint8List> stream,
-      Uint8List terminator, int maxLen: 1024, bool stripTerminator: true) {
+  static Transaction<Uint8List> terminated(
+      Stream<Uint8List> stream, Uint8List terminator,
+      {int maxLen: 1024, bool stripTerminator: true}) {
     return Transaction<Uint8List>(
         stream,
         TerminatedTransformer.broadcast(
@@ -56,9 +57,12 @@ class Transaction<T> {
   /// Transaction.magicHeader(p.inputStream, Uint8List.fromList([65,65,65])); // expects magic header AAA and then byte of length.
   /// ```
   static Transaction<Uint8List> magicHeader(
-      Stream<Uint8List> stream, List<int> header) {
+      Stream<Uint8List> stream, List<int> header,
+      {int maxLen: 1024}) {
     return Transaction<Uint8List>(
-        stream, MagicHeaderAndLengthByteTransformer.broadcast(header: header));
+        stream,
+        MagicHeaderAndLengthByteTransformer.broadcast(
+            header: header, maxLen: maxLen));
   }
 
   /// Create a transaction that transforms the incoming stream into
@@ -68,9 +72,14 @@ class Transaction<T> {
   /// var c = Transaction.stringTerminated(p.inputStream, Uint8List.fromList([13, 10]));
   /// ```
   static Transaction<String> stringTerminated(
-      Stream<Uint8List> stream, Uint8List terminator) {
+      Stream<Uint8List> stream, Uint8List terminator,
+      {int maxLen: 1024, bool stripTerminator: true}) {
     return Transaction<String>(
-        stream, TerminatedStringTransformer.broadcast(terminator: terminator));
+        stream,
+        TerminatedStringTransformer.broadcast(
+            terminator: terminator,
+            maxLen: maxLen,
+            stripTerminator: stripTerminator));
   }
 
   /// Transaction Constructor, pass it the untransformed input stream and