@@ -43,8 +43,8 @@ public function testSseBufferIsBoundedByConfiguredCap(): void
4343
4444 $ this ->invokeProcessSseStream ($ transport );
4545
46- self :: assertSame ('' , $ this ->readPrivate ($ transport , 'sseBuffer ' ), 'buffer must be cleared on abort ' );
47- self :: assertNull ($ this ->readPrivate ($ transport , 'activeStream ' ), 'stream must be released on abort ' );
46+ $ this -> assertSame ('' , $ this ->readPrivate ($ transport , 'sseBuffer ' ), 'buffer must be cleared on abort ' );
47+ $ this -> assertNull ($ this ->readPrivate ($ transport , 'activeStream ' ), 'stream must be released on abort ' );
4848 }
4949
5050 #[TestDox('aborting the SSE stream fails the in-flight request immediately instead of waiting for its timeout ' )]
@@ -60,9 +60,9 @@ public function testAbortFailsPendingRequestFast(): void
6060 $ this ->invokeProcessSseStream ($ transport );
6161
6262 $ response = $ state ->consumeResponse (1 );
63- self :: assertInstanceOf (Error::class, $ response );
64- self :: assertSame (Error::INTERNAL_ERROR , $ response ->code );
65- self :: assertSame (1 , $ response ->id );
63+ $ this -> assertInstanceOf (Error::class, $ response );
64+ $ this -> assertSame (Error::INTERNAL_ERROR , $ response ->code );
65+ $ this -> assertSame (1 , $ response ->id );
6666 }
6767
6868 #[TestDox('well-formed delimited events are parsed and dispatched ' )]
@@ -78,7 +78,7 @@ public function testWellFormedEventsStillParse(): void
7878
7979 $ this ->invokeProcessSseStream ($ transport );
8080
81- self :: assertSame (['hello ' , 'world ' ], $ messages );
81+ $ this -> assertSame (['hello ' , 'world ' ], $ messages );
8282 }
8383
8484 #[TestDox('the buffer cap must be a positive number of bytes ' )]
0 commit comments