MWCallbackStream.php

Go to the documentation of this file.

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