MWCallbackStream.php

Go to the documentation of this file.

<?php
use GuzzleHttp\Psr7\StreamDecoratorTrait;
use GuzzleHttp\Psr7\Utils;
use Psr\Http\Message\StreamInterface;
 
class MWCallbackStream implements StreamInterface {
    use StreamDecoratorTrait;
 
    private $callback;
 
    public function __construct( callable $cb ) {
        $this->stream = Utils::streamFor();
        $this->callback = $cb;
    }
 
    public function write( $string ) {
        return call_user_func( $this->callback, $this, $string );
    }
}