build: fix jooby/src/test/java/io/jooby/internal/handler/ChunkedSubscriberTest.java

Author: jknack

jooby/src/test/java/io/jooby/internal/handler/ChunkedSubscriberTest.java

@@ -146,12 +146,15 @@ void testOnNextExceptionInEncode() throws Exception {
     RuntimeException ex = new RuntimeException("encoder error");
     when(encoder.encode(ctx, item)).thenThrow(ex);
 
+    when(ctx.getMethod()).thenReturn("GET");
+    when(ctx.getRequestPath()).thenReturn("/path");
+
     ChunkedSubscriber sub = new ChunkedSubscriber(ctx);
     sub.onSubscribe(subscription);
     sub.onNext(item);
 
+    verify(subscription).cancel();
     verify(ctx).sendError(ex);
-    verify(subscription).cancel(); // Automatically cancels on exception
   }
 
   @Test
@@ -161,6 +164,9 @@ void testOnNextCallbackError() throws Exception {
     when(encoder.encode(ctx, item)).thenReturn(data);
     when(mediaType.isJson()).thenReturn(false);
 
+    when(ctx.getMethod()).thenReturn("GET");
+    when(ctx.getRequestPath()).thenReturn("/path");
+
     ChunkedSubscriber sub = new ChunkedSubscriber(ctx);
     sub.onSubscribe(subscription);
     sub.onNext(item);
@@ -170,11 +176,10 @@ void testOnNextCallbackError() throws Exception {
 
     Exception ex = new Exception("write error");
 
-    // Simulate write failure (x != null)
     captor.getValue().onComplete(ctx, ex);
 
-    verify(ctx).sendError(ex);
     verify(subscription).cancel();
+    verify(ctx).sendError(ex);
   }
 
   @Test
@@ -265,6 +270,9 @@ void testOnCompleteJsonError() throws Exception {
     when(encoder.encode(ctx, item)).thenReturn(data);
     when(mediaType.isJson()).thenReturn(true);
 
+    when(ctx.getMethod()).thenReturn("GET");
+    when(ctx.getRequestPath()).thenReturn("/path");
+
     ChunkedSubscriber sub = new ChunkedSubscriber(ctx);
     sub.onSubscribe(subscription);
     sub.onNext(item);
@@ -276,6 +284,7 @@ void testOnCompleteJsonError() throws Exception {
     verify(sender).write(any(byte[].class), captor.capture());
 
     Exception err = new Exception("complete callback error");
+
     captor.getValue().onComplete(ctx, err);
 
     verify(ctx).sendError(err);