PHPackages                             miquido/observable - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. miquido/observable

ActiveLibrary

miquido/observable
==================

Observable library

v1.0.0(7y ago)51511MITPHPPHP ^7.1.3

Since Sep 26Pushed 7y ago3 watchersCompare

[ Source](https://github.com/miquido/observable)[ Packagist](https://packagist.org/packages/miquido/observable)[ Docs](https://github.com/miquido/observable)[ RSS](/packages/miquido-observable/feed)WikiDiscussions master Synced 3d ago

READMEChangelog (1)Dependencies (4)Versions (3)Used By (1)

[![Build](https://camo.githubusercontent.com/deed6953fe0d4c60ecdf73e1266b0d214a23d31cbfba7ee1f92c9433bad01aa6/68747470733a2f2f7472617669732d63692e6f72672f6d69717569646f2f6f627365727661626c652e7376673f6272616e63683d6d6173746572)](https://travis-ci.org/miquido/observable)[![Maintainability](https://camo.githubusercontent.com/476f37c934b7475afff7022d677d4c190ce568959f32833e56e3f8a8fabb1cd5/68747470733a2f2f6170692e636f6465636c696d6174652e636f6d2f76312f6261646765732f65363061393365353364646465386133383735632f6d61696e7461696e6162696c697479)](https://codeclimate.com/github/miquido/observable/maintainability)[![Test Coverage](https://camo.githubusercontent.com/12d7e3f37f31cf83751261d2b303d4b123de3514a18fe21ffc3a8b879b50ba80/68747470733a2f2f6170692e636f6465636c696d6174652e636f6d2f76312f6261646765732f65363061393365353364646465386133383735632f746573745f636f766572616765)](https://codeclimate.com/github/miquido/observable/test_coverage)[![MIT Licence](https://camo.githubusercontent.com/fabb40ab22588a0746bb0916ed92739171bde7fb31f281c627aa588bcba62cc2/68747470733a2f2f6261646765732e66726170736f66742e636f6d2f6f732f6d69742f6d69742e7376673f763d313033)](https://opensource.org/licenses/mit-license.php)

Observable
==========

[](#observable)

Set of classes for data streams.

- [Installation guide](#installation)
- [Code Samples](#code-samples)
- [Contributing](#contributing)

Installation
------------

[](#installation)

Use [Composer](https://getcomposer.org) to install the package:

```
composer require miquido/observable
```

Code Samples
------------

[](#code-samples)

- [Create and subscribe to a data stream](#create-and-subscribe-to-a-data-stream)
- [Manipulate data in a stream with *Operators*](#manipulate-data-in-a-stream-with-operators)
- [Using a *Subject*](#using-a-subject)
- [List of build-in operators](#list-of-build-in-operators)

Please also check [miquido/csv-file-reader](https://github.com/miquido/csv-file-reader) library for more real-life examples.

### Create and subscribe to a data stream

[](#create-and-subscribe-to-a-data-stream)

You can start with simple *Miquido\\Observable\\Stream\\FromArray::create* method.

```