Skip to content

Latest commit

 

History

History
20 lines (17 loc) · 540 Bytes

Sink.md

File metadata and controls

20 lines (17 loc) · 540 Bytes

Sink

A Callbag sinker that will only emit next, and completed events. And it returns a Cancellable.

Examples

_ = from(0...5)
  |> sink(print) // next(0)
                 // next(1)
                 // next(2)
                 // next(3)
                 // next(4)
                 // completed(.finished)