monolib_dart

What's Changed

• feat(monolib-dart): add onError callback to tryAdd and tryAddError by @TarasMazepa in #125

Full Changelog: monolib-dart-v0.0.54...monolib-dart-v0.0.55

• Adds onError callbacks to tryAdd and tryAddError stream extensions to allow reporting of swallowed exceptions.

What's Changed

• feat: add onDone callback to CsvMappedDecoder and JsonlMappedDecoder by @TarasMazepa in #124

Full Changelog: monolib-dart-v0.0.53...monolib-dart-v0.0.54

• Adds onDone callback to CsvMappedDecoder and JsonlMappedDecoder.

What's Changed

• feat: Add onDone callback to Csv and Jsonl mapped batch decoders by @TarasMazepa in #123

Full Changelog: monolib-dart-v0.0.52...monolib-dart-v0.0.53

• Adds onDone callback to CsvMappedBatchDecoder and JsonlMappedBatchDecoder.

What's Changed

• refactor: tryAdd and tryAddError as Sink extensions by @TarasMazepa in #122

Full Changelog: monolib-dart-v0.0.51...monolib-dart-v0.0.52

• Refactors tryAdd and tryAddError extensions to apply to Sink and EventSink instead of just StreamController, enabling broader usage across all sink types while maintaining StreamController-specific fast paths.

What's Changed

• chore: update AGENTS.md by @TarasMazepa in #120
• feat(stream): Add tryAddError and ignoreError flag to StreamController extensions by @TarasMazepa in #121

Full Changelog: monolib-dart-v0.0.50...monolib-dart-v0.0.51

• Adds tryAddError to StreamController extensions.
• Adds an optional ignoreError boolean to tryAdd and tryAddError which will catch and suppress exceptions when adding to a stream.

What's Changed

• feat: make joinWith empty list behavior configurable by @TarasMazepa in #119

Full Changelog: monolib-dart-v0.0.49...monolib-dart-v0.0.50

• Updates joinWith method in OnList extension to accept an ifEmpty callback parameter.

What's Changed

• feat: Adds OnListOfString joinWith method and prepares 0.0.49 release by @TarasMazepa in #118

Full Changelog: monolib-dart-v0.0.48...monolib-dart-v0.0.49

• Adds joinWith method to OnList extension.

What's Changed

• Fix concurrent write crashes in jsonl batch writer by adding write queue by @TarasMazepa in #117

Full Changelog: monolib-dart-v0.0.47...monolib-dart-v0.0.48

• Fixes concurrent write crashes in Batcher by guaranteeing that internal onBatch executions run sequentially, preventing overlapping IOSink flush/write errors.

What's Changed

• refactor: extract encode batch async and lazy string sink by @TarasMazepa in #116

Full Changelog: monolib-dart-v0.0.46...monolib-dart-v0.0.47

• Refactors async encoders to DRY up string sink lazy initialization and batch encoding by introducing withLazyStringSink and encodeBatchAsync utilities.

What's Changed

• release: 0.0.46 with onBatch callback by @TarasMazepa in #115

Full Changelog: monolib-dart-v0.0.45...monolib-dart-v0.0.46

• Adds onBatch callback to CsvMappedBatchDecoder and JsonlMappedBatchDecoder.

• Adds csvEncodeBatchAsync and jsonlEncodeBatchAsync to encode streams of batches.

• Adds flattenToList({bool cancelOnError = true, bool sync = false}) extension method to Stream<List<T>> to efficiently gather and flatten all emitted lists into a single Future<List<T>>.

• BREAKING: csvEncodeAsync now uses named arguments ({required Object items, StringSink? sink, StringSink Function()? sinkProvider}) to match jsonlEncodeAsync.
• Align CsvCodec with JsonlCodec by introducing a const constructor and migrating encoder and decoder fields to getters.

• Complete API symmetry for JSONL decoders by propagating jsonCodec through JsonlMappedDecoder and JsonlMappedBatchDecoder, allowing custom JSON decoders to be injected.

• Added always_use_package_imports lint rule and applied it project-wide.
• DRY up in-memory CsvDecoder and JsonlDecoder by delegating structural parsing to their respective chunked decoders.
• Extract BatchingSinkMixin to remove batching boilerplate from mapped batch decoders.
• Extract iterateStreamOrIterable to consolidate stream/iterable iteration in async encoders.

• Performs DRY cleanup on JSONL decoders by moving line sanitization (stripping carriage returns and empty line checks) directly into JsonlBaseChunkSink.

• BREAKING: Removed csvEncodeAsyncForIOSink, jsonlEncodeAsyncForIOSink, and jsonEncodeAsyncForIOSink utilities.
• Extracts duplicated CSV cell escaping logic into csv_cell_writer.dart to DRY up encoders.

• Performs massive DRY refactoring on chunked decoders by extracting duplicated structural parsing logic into CsvBaseChunkSink and JsonlBaseChunkSink.

• Extracts duplicate convert implementation from chunked decoders into a common ChunkedOnlyConverter base class.
• Resolves internal private sink naming collisions for mapped CSV decoders.

• Renames CsvRowDecoder to CsvChunkedDecoder and JsonlMapper to JsonlChunkedDecoder to complete the decoder API matrix unification.
• Rewrites JsonlChunkedDecoder to handle its own chunk boundary line splitting, maximizing performance.

• Adds CsvMappedBatchDecoder and JsonlMappedBatchDecoder for high-throughput batch-emitting stream optimizations.
• Renames MappedCsvRowDecoder to CsvMappedDecoder and JsonlSplitMapper to JsonlMappedDecoder to unify naming conventions.

• Adds JsonlSplitMapper converter that fuses line-splitting directly into JSON mapping, eliminating intermediate stream event overhead.

• Refactors MappedCsvRowDecoder and CsvRowDecoder to use synchronous StreamController instead of Stream.multi to preserve standard stream contracts and lifecycle hooks.

• Guarantees jsonlEncodeAsync outputs a trailing newline even if item serialization throws an error.
• BREAKING: Removes OnFunctionWithOneArgument (withAnArgument).
• BREAKING: Removes asArgumentIn and quotingString from OnObject.

• Adds mapLists and whereElements to OnStreamOfLists extension on Stream<List<T>>.
• Adds OnIterableOfNullableBoolFunctions extension with combinedEvery and combinedAny.
• Moves OnNullableString extension with emptyToNull into on_nullable_string.dart.
• Enhances Batcher documentation and streamlines internal batch tracking.
• BREAKING: Removes mapCatching from OnIterable.
• BREAKING: Removes compareChainReverse from OnBool.
• BREAKING: Removes discardedByFloor from OnDouble.
• BREAKING: Removes OnIterableOfListOfString (skipFirstIfIsCsvHeaderRow).
• BREAKING: Removes OnListOfString (isTrimmedDeepEqualsTo).
• BREAKING: Removes OnString (removeEndingNewLine, ensureEndsWithADot, removeEnclosingQuotationMarks).
• BREAKING: Removes NullIOSink.
• BREAKING: Removes OnFunctionReturningList (asSkippingMappedToEmptyExpander).

• Adds JsonlBatchWriter component to efficiently write high-frequency data to a JSONL file in batches.

• Adds AsyncJsonWritable interface for providing inversion-of-control when encoding objects asynchronously in jsonEncodeAsync.
• Adds StreamingJsonString which allows streaming strings directly into the output sink without holding them in memory.

• BREAKING: Removes jsonEncodeAsyncForIOSinkProvider and jsonlEncodeAsyncForIOSinkProvider.
• Refactors jsonlEncodeAsync to use a late variable for sink initialization.
• Cleans up and sorts exports in fluent_json.dart, monolib_dart.dart, and stream.dart.

• BREAKING: Updates signatures for async JSON/JSONL encoders (jsonEncodeAsync, jsonlEncodeAsync) to use named arguments (items, sink, sinkProvider).
• Introduces lazy initialization via sinkProvider for async encoders. Sinks are now memoized and only spun up upon the first write operation, saving resources for empty streams/iterables.
• Adds automatic resource cleanup (close()) for sinks spawned by sinkProvider, while respecting caller ownership for directly provided sinks.
• Adds jsonEncodeAsyncForIOSinkProvider and jsonlEncodeAsyncForIOSinkProvider to support lazy IOSink resolution.

• Adds JsonlMapper and JsonlMapperSinkInternal for mapping JSON from chunked JSONL strings.
• Fuses utf8 decoding with line splitting in utf8DecodeAndLineSplit extension on Stream<List<int>>.

• Adds MappedCsvRowDecoder for streaming asynchronous chunked CSV parsing with mapping and filtering support.

• Adds LazyJson class to defer JSON evaluation.

• Adds StreamWhereTypeExtension with whereType<R>() method to Stream.
• Adds MapNotNullStreamExtension with mapNotNull<R>() method to Stream.

• Adds CsvRowDecoder for streaming asynchronous chunked CSV parsing.
• Adds rfc4180 compatibility parity tests for Csv encoders/decoders.

• Adds Iso8601WithTimeZone extension on DateTime with toIso8601StringWithTz method.

• Adds Flag and related models (FlagFindResult, FlagFindType, OptionalFlagResult) for parsing CLI arguments to cli.dart.

• Adds Zalgo encoding and decoding functions

• CsvDecoder - ensuring that no empty lists would be output at the end of the csv list of lists

• Enhances Batcher with proper asynchronous disposal (waits for all in-flight batches) and allows nullable limits (maxBatchSize / maxDuration). Adds throwOnAddAfterDispose configuration flag.
• Adds OnStreamOfListOfInt extension on Stream<List<int>> with readLine() and utf8DecodeAndLineSplit().

• Adds jsonEncodeAsyncForIOSink, jsonlEncodeAsyncForIOSink, and csvEncodeAsyncForIOSink

• Adds csvEncodeAsync asynchronous CSV stream encoder
• Adds OnFutureFunction extension with asyncCallWithRetryOnFailure and asyncRetryOnFailure global function

• Adds withIOSink to IOSink

• Adds withIOSink to IOSink Function()

• Actually adds jsonlEncodeAsync

• Adds jsonlEncodeAsync

• Adds toExtendedRadixString extension method to int
• Removes min() and max() extension methods

• Adds OnString.parseAsFluentJson extension
• Adds CSV codec and extensions
• Adds OnDouble, OnFunctionWithNoArguments, OnFunctionWithOneArgument, OnIterableOfNum, OnListOfLists, and OnString extensions.
• Adds TableCellAlignLeft and TableCellAlignRight for table formatting.

• Fixes ConcurrentModificationError in PillarChangeNotifier during notification.
• Extracts PillarChangeNotifierInternal into a separate file.

• Adds JsonlCodec
• Adds OnIterableOfStreamControllers
• Adds OnFunctionReturningList
• Adds OnListOfStreamControllers
• Adds OnStreamController
• Adds OnStreamOfLists
• Adds SingleValueCachingStream
• Adds StreamWithClose

• Adds NullIOSink

• Changes jsonEncodeAsync signature to use Object? instead of dynamic

• Adds jsonEncodeAsync streaming JSON encoder

• Adds various extension methods
• Adds FluentJson

• Initial version.