Merge pull request #44 from clue-labs/revert-24-remove-progress-from-buffered-sink

Revert "BufferedSink: Remove progress notifications"

Author: clue

src/BufferedSink.php

@@ -31,6 +31,7 @@ public function handleErrorEvent($e)
     public function write($data)
     {
         $this->buffer .= $data;
+        $this->deferred->progress($data);
     }
 
     public function close()

tests/BufferedSinkTest.php

@@ -107,19 +107,30 @@ public function errorsShouldRejectPromise()
     }
 
     /** @test */
-    public function writeShouldNotTriggerProgressOnPromise()
+    public function writeShouldTriggerProgressOnPromise()
     {
         $callback = $this->createCallableMock();
         $callback
-            ->expects($this->never())
-            ->method('__invoke');
+            ->expects($this->at(0))
+            ->method('__invoke')
+            ->with('foo');
+        $callback
+            ->expects($this->at(1))
+            ->method('__invoke')
+            ->with('bar');
+        $callback
+            ->expects($this->at(2))
+            ->method('__invoke')
+            ->with('baz');
 
         $sink = new BufferedSink();
         $sink
             ->promise()
             ->then(null, null, $callback);
 
         $sink->write('foo');
+        $sink->write('bar');
+        $sink->end('baz');
     }
 
     /** @test */