src/Observable.php
public function take(int $count): Observable
    {
        if ($count === 0) {
            return self::empty();
        }

        return $this->lift(function () use ($count) {
            return new TakeOperator($count);
        });
    }
public function take(int $count): Observable
    {
        if ($count === 0) {
            return self::empty();
        }

        return $this->lift(function () use ($count) {
            return new TakeOperator($count);
        });
    }
public function take ( int $ count ) : Observable { if ( $ count === 0 ) { return self :: empty ( ) ; } return $ this -> lift ( function ( ) use ( $ count ) { return new TakeOperator ( $ count ) ; } ) ; }
Returns a specified number of contiguous elements from the start of an observable sequence

@param integer $count
@return Observable|EmptyObservable

@demo take/take.php
@operator
@reactivex take
Returns a specified number of contiguous elements from the start of an observable sequence