Stream Operators

Stream operators are components that help transform and manipulate data streams. They allow you to quickly and efficiently add or remove events, combine data from multiple streams, or perform more complex manipulations. This makes them a powerful and essential part of Kelp's data flow.

Each stream operator in Kelp has a unique purpose and can be used to solve specific tasks. They are divided into the following categories:

Combining operators

• Combine
• Zip

Filtering operators

• Filter
• Filter By
• Sample By
• Skip
• Skip Duplicates
• Skip While
• Skip Until By
• Sliding Window
• Take
• Take Until By
• Take While

Buffering operators

• Buffer By
• Buffer While By
• Buffer With Count
• Buffer With Time
• Iterator
• Gate

Time-based operators

• Debounce
• Delay
• Interval
• Sequentially
• Throttle

Misc operators

• Flatten Deep
• Fork
• Port

In this section, we’ll describe each streaming operator in detail, providing examples and best practices for using them effectively.