Find this useful? Enter your email to receive occasional updates for securing PHP code.

Signing you up...

Thank you for signing up!

PHP Decode

<?php namespace Rx\Observable; use Rx\Observable; use Rx\ObserverInterface; use Rx\Obser..

Decoded Output download

<?php

namespace Rx\Observable;

use Rx\Observable;
use Rx\ObserverInterface;
use Rx\ObservableInterface;
use Rx\Observer\CallbackObserver;
use Rx\Disposable\CompositeDisposable;
use Rx\DisposableInterface;

class GroupedObservable extends Observable
{
    private $key;
    private $underlyingObservable;

    public function __construct($key, ObservableInterface $underlyingObservable, DisposableInterface $mergedDisposable = null)
    {
        $this->key = $key;

        if (null === $mergedDisposable) {
            $this->underlyingObservable = $underlyingObservable;
        } else {
            $this->underlyingObservable = new AnonymousObservable(
                function ($observer, $scheduler) use ($mergedDisposable, $underlyingObservable) {
                    // todo, typehint $mergedDisposable?
                    return new CompositeDisposable([
                        $mergedDisposable->getDisposable(),
                        $underlyingObservable->subscribe($observer, $scheduler),
                    ]);
                }
            );
        }
    }

    public function getKey()
    {
        return $this->key;
    }

    public function subscribe(ObserverInterface $observer, $scheduler = null)
    {
        return $this->underlyingObservable->subscribe($observer, $scheduler);
    }
}
 ?>

Did this file decode correctly?

Original Code

<?php

namespace Rx\Observable;

use Rx\Observable;
use Rx\ObserverInterface;
use Rx\ObservableInterface;
use Rx\Observer\CallbackObserver;
use Rx\Disposable\CompositeDisposable;
use Rx\DisposableInterface;

class GroupedObservable extends Observable
{
    private $key;
    private $underlyingObservable;

    public function __construct($key, ObservableInterface $underlyingObservable, DisposableInterface $mergedDisposable = null)
    {
        $this->key = $key;

        if (null === $mergedDisposable) {
            $this->underlyingObservable = $underlyingObservable;
        } else {
            $this->underlyingObservable = new AnonymousObservable(
                function ($observer, $scheduler) use ($mergedDisposable, $underlyingObservable) {
                    // todo, typehint $mergedDisposable?
                    return new CompositeDisposable([
                        $mergedDisposable->getDisposable(),
                        $underlyingObservable->subscribe($observer, $scheduler),
                    ]);
                }
            );
        }
    }

    public function getKey()
    {
        return $this->key;
    }

    public function subscribe(ObserverInterface $observer, $scheduler = null)
    {
        return $this->underlyingObservable->subscribe($observer, $scheduler);
    }
}

Function Calls

None

Variables

None

Stats

MD5 7cbf2b49a7a4e8c5e880f79a7e6b69e0
Eval Count 0
Decode Time 113 ms