2.0-alpha Menu

Take 3 and complete


❚ take returns a new stream of at most amount values:

  • When the input stream emits its n-th value:
    • if n < amount, the event can pass
    • if n == amount, the event can pass and the stream immediately completes

Stream completion

What does “the stream completes” mean? As a reminder, a stream is a sequence of events over time. And you can subscribe to a stream, using a listener. Let’s dive into the details now:

  • A stream can emit three kinds of events:
    • values
    • an × error: e
    • a ◉ complete notification
  • After an × error: e or a ◉ complete notification, nothing else is emitted by the stream.
  • A listener can receive those three kinds of events. So, it can consume the values, handle an error and act upon completion of the subscribed stream.

See also


takeLast vs take

take vs last

💌 I create something new each week!
Learn Reactive Programming and stay tuned.

Occasional updates, plus:

Cédric Soulas - Freelance Developer Advocate. Learn more.

Follow 👨‍💻 Hire me