@@ -240,6 +240,10 @@ public void testNormalCalls() {
240240 assertEquals (
241241 Flow .Action .Noop .INSTANCE ,
242242 cbp .getCallback (events .requestFilesFilenames ()).apply (null , null ).getAction ());
243+ ss .registerCallback (events .requestFilesContent (), callback );
244+ assertEquals (
245+ Flow .Action .Noop .INSTANCE ,
246+ cbp .getCallback (events .requestFilesContent ()).apply (null , null ).getAction ());
243247 ss .registerCallback (events .fileWritten (), callback );
244248 cbp .getCallback (events .fileWritten ()).apply (null , null );
245249 assertEquals (Events .MAX_EVENTS , callback .count );
@@ -331,6 +335,9 @@ public void testThrowableBlocking() {
331335 ss .registerCallback (events .requestFilesFilenames (), throwback );
332336 assertEquals (
333337 Flow .ResultFlow .empty (), cbp .getCallback (events .requestFilesFilenames ()).apply (null , null ));
338+ ss .registerCallback (events .requestFilesContent (), throwback );
339+ assertEquals (
340+ Flow .ResultFlow .empty (), cbp .getCallback (events .requestFilesContent ()).apply (null , null ));
334341 ss .registerCallback (events .fileWritten (), throwback );
335342 cbp .getCallback (events .fileWritten ()).apply (null , null );
336343 assertEquals (Events .MAX_EVENTS , throwback .count );
0 commit comments