Available operators

Transformation operators

• bufferCount()
• bufferWhile()
• flatten()
• leftJoin()
• map()
• merge()
• reverse()
• sort()

Filtering operators

• distinct()
• filter()
• skip()
• take()

Asserting operators

• ifEmpty()
• overflow()

Error handling operators

• finalize()

Utility operators

• tap()