@Override
    public Object handle(ProceedingJoinPoint proceedingJoinPoint, Bulkhead bulkhead,
        String methodName) throws Throwable {
        BulkheadOperator<?> bulkheadOperator = BulkheadOperator.of(bulkhead);
        Object returnValue = proceedingJoinPoint.proceed();
        return executeRxJava2Aspect(bulkheadOperator, returnValue);
    }
@Test
    public void testReactorTypes() throws Throwable {
        Bulkhead bulkhead = Bulkhead.ofDefaults("test");

        when(proceedingJoinPoint.proceed()).thenReturn(Single.just("Test"));
        assertThat(rxJava2BulkheadAspectExt.handle(proceedingJoinPoint, bulkhead, "testMethod"))
            .isNotNull();

        when(proceedingJoinPoint.proceed()).thenReturn(Flowable.just("Test"));
        assertThat(rxJava2BulkheadAspectExt.handle(proceedingJoinPoint, bulkhead, "testMethod"))
            .isNotNull();
    }