take

1 input stream amount

  • When the input stream emits its n-th value
    • if n < amount, the value is emitted
    • if n == amount, the value is emitted and the stream immediately completes

returns a new stream of at most amount values

take

❚ 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


takeWhile


takeLast vs take


take vs last

💌 Learn Reactive Programming and stay tuned

Occasional updates, plus:

News

@CedricSoulas