async/stream_window_utils library
Stream windowing (time- and count-based) — roadmap #660.
Functions
-
windowCount<
T> (Stream< T> stream, int count) → Stream<List< T> > -
Buffers
streaminto lists ofcountelements.
- saropa_dart_utils package
- documentation
- async/stream_window_utils.dart
saropa_dart_utils package
- Libraries
- async/async_barrier_utils
- async/async_more_utils
- async/async_mutex_utils
- async/async_semaphore_utils
- async/batch_async_utils
- async/batch_flush_utils
- async/cancel_previous_exception
- async/circuit_breaker_utils
- async/debounce_utils
- async/delay_utils
- async/exponential_backoff_utils
- async/heartbeat_utils
- async/idempotent_async_utils
- async/memoize_future_utils
- async/race_cancel_utils
- async/retry_policy_utils
- async/retry_utils
- async/sequential_async_utils
- async/stream_buffer_utils
- async/stream_window_utils
- async/throttle_utils
- async/timeout_fallback_utils
- async/timeout_policy_utils
- base64/base64_utils
- base64/gzip_codec_io
- base64/gzip_codec_stub
- bool/bool_iterable_extensions
- bool/bool_string_extensions
- caching/lru_cache
- caching/memoize_sync_utils
- caching/size_limit_cache
- caching/ttl_cache
- collections/balanced_partition_utils
- collections/bimap_utils
- collections/bin_packing_utils
- collections/bloom_filter_utils
- collections/chunk_overlap_utils
- collections/columnar_view_utils
- collections/damerau_levenshtein_utils
- collections/dedup_set_expiry_utils
- collections/difference_array_utils
- collections/disjoint_set_utils
- collections/greedy_set_cover_utils
- collections/histogram_utils
- collections/interval_scheduling_utils
- collections/inverted_index_utils
- collections/kmeans_utils
- collections/knapsack_utils
- collections/lcs_substring_utils
- collections/lis_utils
- collections/multi_criteria_sort_utils
- collections/multiset_utils
- collections/nway_merge_utils
- collections/online_mean_variance_utils
- collections/pivot_unpivot_utils
- collections/prefix_frequency_utils
- collections/priority_map_utils
- collections/reservoir_sampling_utils
- collections/ring_buffer_utils
- collections/rolling_hash_utils
- collections/row_column_table_utils
- collections/run_detection_utils
- collections/seeded_shuffle_utils
- collections/sliding_window_aggregate_utils
- collections/stream_quantile_utils
- collections/string_pool_utils
- collections/time_bucket_utils
- collections/top_k_heap_utils
- collections/trie_utils
- collections/weighted_interval_utils
- collections/window_functions_utils
- datetime/date_constant_extensions
- datetime/date_constants
- datetime/date_time_arithmetic_extensions
- datetime/date_time_bounds_extensions
- datetime/date_time_business_days_utils
- datetime/date_time_calendar_extensions
- datetime/date_time_clamp_extensions
- datetime/date_time_comparison_extensions
- datetime/date_time_extensions
- datetime/date_time_fiscal_extensions
- datetime/date_time_list_extensions
- datetime/date_time_more_extensions
- datetime/date_time_nullable_extensions
- datetime/date_time_overlap_utils
- datetime/date_time_range_utils
- datetime/date_time_relative_utils
- datetime/date_time_timezone_extensions
- datetime/date_time_utils
- datetime/date_time_week_extensions
- datetime/duration_format_utils
- datetime/duration_parse_utils
- datetime/injectable_clock_utils
- datetime/period_split_utils
- datetime/relative_date_bucket_utils
- datetime/time_emoji_utils
- datetime/time_rounding_utils
- datetime/timebox_exception
- double/double_extensions
- double/double_iterable_extensions
- enum/enum_iterable_extensions
- gesture/gesture_utils
- gesture/swipe_properties
- graph/astar_utils
- graph/bfs_dfs_utils
- graph/bipartite_utils
- graph/connected_components_utils
- graph/critical_path_utils
- graph/dag_scheduler_utils
- graph/dijkstra_utils
- graph/floyd_warshall_utils
- graph/graph_diff_utils
- graph/graph_utils
- graph/hierarchy_utils
- graph/line_simplify_utils
- graph/mst_utils
- graph/topological_sort_utils
- graph/tree_utils
- hex/hex_utils
- html/html_entity_data
- html/html_utils
- int/int_extensions
- int/int_iterable_extensions
- int/int_nullable_extensions
- int/int_string_extensions
- int/int_utils
- iterable/comparable_iterable_extensions
- iterable/iterable_cartesian_extensions
- iterable/iterable_diff_extensions
- iterable/iterable_extensions
- iterable/iterable_first_last_extensions
- iterable/iterable_flatten_deep_extensions
- iterable/iterable_flatten_extensions
- iterable/iterable_group_by_extensions
- iterable/iterable_indexed_extensions
- iterable/iterable_list_ops_extensions
- iterable/iterable_min_max_extensions
- iterable/iterable_more_extensions
- iterable/iterable_pairs_extensions
- iterable/iterable_sort_extensions
- iterable/iterable_split_extensions
- iterable/iterable_symmetric_diff_extensions
- iterable/occurrence
- iterable/run_length_utils
- json/json_epoch_scale
- json/json_iterables_utils
- json/json_type_utils
- json/json_utils
- list/list_binary_search_extensions
- list/list_default_empty_extensions
- list/list_extensions
- list/list_lower_extensions
- list/list_nullable_extensions
- list/list_of_list_extensions
- list/list_rotate_extensions
- list/list_shuffle_seeded_extensions
- list/list_string_extensions
- list/list_top_k_extensions
- list/make_list_extensions
- list/unique_list_extensions
- map/deep_equality_utils
- map/map_deep_merge_extensions
- map/map_deep_utils
- map/map_default_extensions
- map/map_diff_utils
- map/map_extensions
- map/map_flatten_extensions
- map/map_from_entries_extensions
- map/map_invert_extensions
- map/map_merge_extensions
- map/map_more_extensions
- map/map_nested_extensions
- map/map_nullable_extensions
- map/map_pick_omit_extensions
- map/map_transform_extensions
- niche/checksum_utils
- niche/color_utils
- niche/hash_utils
- niche/name_utils
- niche/natural_sort_utils
- niche/niche_more_utils
- niche/pad_format_utils
- niche/random_string_utils
- niche/string_diff_utils
- num/math_utils
- num/num_clamp_extensions
- num/num_compact_parse_extensions
- num/num_extensions
- num/num_factorial_utils
- num/num_format_extensions
- num/num_iterable_extensions
- num/num_lerp_utils
- num/num_locale_utils
- num/num_min_max_utils
- num/num_modulo_utils
- num/num_more_extensions
- num/num_prime_utils
- num/num_range_extensions
- num/num_range_inclusive_extensions
- num/num_round_multiple_extensions
- num/num_safe_division_extensions
- num/num_stats_utils
- num/num_utils
- object/assert_utils
- object/cast_utils
- object/coalesce_utils
- object/copy_with_defaults_utils
- object/default_value_extensions
- object/identity_utils
- object/nullable_more_extensions
- object/pipe_compose_utils
- object/pipe_utils
- object/require_utils
- object/shallow_copy_utils
- parsing/canonicalize_json_utils
- parsing/changelog_section_utils
- parsing/config_precedence_utils
- parsing/csv_dialect_utils
- parsing/csv_parse_utils
- parsing/email_validation_utils
- parsing/hex_color_utils
- parsing/isbn_utils
- parsing/json_diff_patch_utils
- parsing/luhn_utils
- parsing/nested_query_parser_utils
- parsing/parse_bool_utils
- parsing/parse_list_utils
- parsing/parser_error_utils
- parsing/parsing_more_utils
- parsing/phone_normalize_utils
- parsing/semver_utils
- parsing/size_parse_utils
- parsing/validate_non_empty_utils
- parsing/varint_utils
- parsing/version_compare_utils
- parsing/version_parse_utils
- random/common_random
- regex/regex_common_utils
- regex/regex_match_utils
- saropa_dart_utils
- stats/bucketed_aggregate_utils
- stats/confidence_interval_utils
- stats/correlation_utils
- stats/data_normalization_utils
- stats/feature_encoding_utils
- stats/funnel_utils
- stats/linear_regression_utils
- stats/log_transform_utils
- stats/metric_rollup_utils
- stats/moving_average_utils
- stats/outlier_mad_utils
- stats/percentile_rank_utils
- stats/quantile_summary_utils
- stats/retention_utils
- stats/robust_stats_utils
- stats/sampling_utils
- string/acronym_extract_utils
- string/apply_patch_utils
- string/between_result
- string/code_block_extract_utils
- string/did_you_mean_utils
- string/diff_render_utils
- string/duplicate_doc_utils
- string/email_quote_strip_utils
- string/excerpt_utils
- string/fuzzy_search_utils
- string/glob_utils
- string/html_sanitizer_utils
- string/human_name_parser_utils
- string/levenshtein_utils
- string/markdown_plain_utils
- string/markdown_snippet_utils
- string/myers_diff_utils
- string/ngram_utils
- string/safe_html_excerpt_utils
- string/search_index_utils
- string/search_query_parser_utils
- string/sensitive_scrub_utils
- string/slug_dedup_utils
- string/soundex_utils
- string/spelling_key_lookup_utils
- string/string_analysis_extensions
- string/string_ansi_extensions
- string/string_between_extensions
- string/string_case_acronym_extensions
- string/string_case_extensions
- string/string_character_extensions
- string/string_csv_extensions
- string/string_diacritics_extensions
- string/string_extensions
- string/string_highlight_extensions
- string/string_indent_extensions
- string/string_key_value_extensions
- string/string_line_extensions
- string/string_lower_extensions
- string/string_manipulation_extensions
- string/string_mask_extensions
- string/string_more_extensions
- string/string_nullable_extensions
- string/string_number_extensions
- string/string_punctuation
- string/string_regex_extensions
- string/string_replace_n_extensions
- string/string_search_extensions
- string/string_slug_extensions
- string/string_split_extensions
- string/string_template_extensions
- string/string_text_extensions
- string/string_unicode_extensions
- string/string_utils
- string/string_wildcard_extensions
- string/string_words_extensions
- string/string_wrap_extensions
- string/template_engine_utils
- string/text_chunk_utils
- string/text_fingerprint_utils
- string/text_normalize_pipeline_utils
- string/text_similarity_utils
- string/tokenize_sentences_utils
- string/url_extract_utils
- testing/debug_utils
- url/path_extension_utils
- url/path_join_utils
- url/path_more_utils
- url/url_absolute_utils
- url/url_build_utils
- url/url_encode_utils
- url/url_extensions
- url/url_query_utils
- uuid/uuid_utils
- uuid/uuid_v4_utils
- validation/cross_field_validation_utils
- validation/data_redaction_utils
- validation/guard_utils
- validation/input_shaping_utils
- validation/ip_cidr_utils
- validation/jwt_structure_utils
- validation/password_strength_utils
- validation/path_validator_utils
- validation/pii_detector_utils
- validation/safe_parse_utils
- validation/safe_temp_name_utils
- validation/typed_positive_utils
- validation/validation_error_utils