public function startInput($source)
    {
        $this->streamingSource = $source;
        $this->is_ended = false;
        $this->onInputStart();
        foreach ($this->destinations as $node) {
            $node->startInput($this);
        }
    }