Handling Data Streams in PHP

Introduction: Understanding Data Streams

Warm greetings! This lesson introduces data streams, which are essentially continuous datasets. Imagine monitoring a weather station or a gaming application that gathers data per second — both generate data streams! We will master handling these data streams using PHP, learning how to access elements, slice segments, and even convert these streams into strings for easier handling.

Representing Data Streams in PHP

In PHP, data streams can be represented using arrays and associative arrays. Let’s consider a straightforward PHP class named DataStream. This class encapsulates operations related to data streams in our program: <?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } } To use it, we create a sample data stream as an instance of our DataStream class, where each element is an associative array: $data = [ ["id" => 1, "value" => 100], ["id" => 2, "value" => 200], ["id" => 3, "value" => 300], ["id" => 4, "value" => 400], ]; $stream = new DataStream($data);

Accessing Elements - Key Operation

To look into individual elements of a data stream, we use indexing. The get() method we introduce below fetches the i+1-th element from the data stream: <?php class DataStream { private $data; public function __construct(array $data) { $this->data = $data; } public function get(int $i): array { if ($i < 0) { $i += count($this->data); } if ($i >= 0 && $i < count($this->data)) { return $this->data[$i]; } else { throw new OutOfRangeException("Index out of range"); } } } Here, we can see the get() method in action: <?php $data = [ ["id" => 1, "value" => 100], ["id" => 2, "value" => 200], ["id" => 3, "value" => 300], ["id" => 4, "value" => 400], ]; $stream = new DataStream($data); try { $elem = $stream->get(2); echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n"; $elem = $stream->get(-1); echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n"; } catch (OutOfRangeException $e) { echo $e->getMessage() . "\n"; } In essence, $stream->get(2) fetched us ["id" => 3, "value" => 300] — the third element (since indexing starts from 0). Meanwhile, $stream->get(-1) fetches the last element, which is ["id" => 4, "value" => 400]. The code snippet if ($i < 0) { $i += count($this->data); } allows negative indexing by converting a negative index into the corresponding positive index, effectively letting -1 refer to the last element, -2 to the second last, and so on. This approach is useful for accessing elements from the end of the data stream efficiently.

Join the 1M+ learners on CodeSignal

Be a part of our community of 1M+ users who develop and demonstrate their skills on CodeSignal

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }
}

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }
}

PHP

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }
}

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }
}

PHP

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

try {
    $elem = $stream->get(2);
    echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";

    $elem = $stream->get(-1);
    echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";
} catch (OutOfRangeException $e) {
    echo $e->getMessage() . "\n";
}

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

try {
    $elem = $stream->get(2);
    echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";

    $elem = $stream->get(-1);
    echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";
} catch (OutOfRangeException $e) {
    echo $e->getMessage() . "\n";
}

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }

    public function slice(int $i, int $j): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($j < 0) {
            $j += count($this->data);
        }
        if ($i >= 0 && $j <= count($this->data) && $i < $j) {
            return array_slice($this->data, $i, $j - $i);
        } else {
            throw new OutOfRangeException("Slice indices out of range");
        }
    }
}

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }

    public function slice(int $i, int $j): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($j < 0) {
            $j += count($this->data);
        }
        if ($i >= 0 && $j <= count($this->data) && $i < $j) {
            return array_slice($this->data, $i, $j - $i);
        } else {
            throw new OutOfRangeException("Slice indices out of range");
        }
    }
}

PHP

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

try {
    $slice = $stream->slice(1, 3);
    foreach ($slice as $elem) {
        echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";
    }
} catch (OutOfRangeException $e) {
    echo $e->getMessage() . "\n";
}

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

try {
    $slice = $stream->slice(1, 3);
    foreach ($slice as $elem) {
        echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";
    }
} catch (OutOfRangeException $e) {
    echo $e->getMessage() . "\n";
}

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }

    public function slice(int $i, int $j): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($j < 0) {
            $j += count($this->data);
        }
        if ($i >= 0 && $j <= count($this->data) && $i < $j) {
            return array_slice($this->data, $i, $j - $i);
        } else {
            throw new OutOfRangeException("Slice indices out of range");
        }
    }

    public function toString(): string {
        $elements = array_map(function($item) {
            return json_encode($item);
        }, $this->data);
        return '[' . implode(', ', $elements) . ']';
    }
}

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }

    public function slice(int $i, int $j): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($j < 0) {
            $j += count($this->data);
        }
        if ($i >= 0 && $j <= count($this->data) && $i < $j) {
            return array_slice($this->data, $i, $j - $i);
        } else {
            throw new OutOfRangeException("Slice indices out of range");
        }
    }

    public function toString(): string {
        $elements = array_map(function($item) {
            return json_encode($item);
        }, $this->data);
        return '[' . implode(', ', $elements) . ']';
    }
}

PHP

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

echo $stream->toString();

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

echo $stream->toString();

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }
}

PHP

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }
}

PHP

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

try {
    $elem = $stream->get(2);
    echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";

    $elem = $stream->get(-1);
    echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";
} catch (OutOfRangeException $e) {
    echo $e->getMessage() . "\n";
}

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }

    public function slice(int $i, int $j): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($j < 0) {
            $j += count($this->data);
        }
        if ($i >= 0 && $j <= count($this->data) && $i < $j) {
            return array_slice($this->data, $i, $j - $i);
        } else {
            throw new OutOfRangeException("Slice indices out of range");
        }
    }
}

PHP

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

try {
    $slice = $stream->slice(1, 3);
    foreach ($slice as $elem) {
        echo "id: " . $elem["id"] . ", value: " . $elem["value"] . "\n";
    }
} catch (OutOfRangeException $e) {
    echo $e->getMessage() . "\n";
}

PHP

<?php

class DataStream {
    private $data;

    public function __construct(array $data) {
        $this->data = $data;
    }

    public function get(int $i): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($i >= 0 && $i < count($this->data)) {
            return $this->data[$i];
        } else {
            throw new OutOfRangeException("Index out of range");
        }
    }

    public function slice(int $i, int $j): array {
        if ($i < 0) {
            $i += count($this->data);
        }
        if ($j < 0) {
            $j += count($this->data);
        }
        if ($i >= 0 && $j <= count($this->data) && $i < $j) {
            return array_slice($this->data, $i, $j - $i);
        } else {
            throw new OutOfRangeException("Slice indices out of range");
        }
    }

    public function toString(): string {
        $elements = array_map(function($item) {
            return json_encode($item);
        }, $this->data);
        return '[' . implode(', ', $elements) . ']';
    }
}

PHP

<?php

$data = [
    ["id" => 1, "value" => 100],
    ["id" => 2, "value" => 200],
    ["id" => 3, "value" => 300],
    ["id" => 4, "value" => 400],
];
$stream = new DataStream($data);

echo $stream->toString();

Introduction: Understanding Data Streams

Representing Data Streams in PHP

Accessing Elements - Key Operation

Join the 1M+ learners on CodeSignal

Slicing - A Useful Technique

Transforming Data Streams to Strings - Another Key Operation

Lesson Summary