public void setCancellationContext(CancellationContext cancellationContext) {
        this.cancellationContext = cancellationContext;
    }
@Test
    void setCancellationContext() {
        CancelableStreamObserver<Object> observer = new CancelableStreamObserver<Object>() {
            @Override
            public void onNext(Object data) {}

            @Override
            public void onError(Throwable throwable) {}

            @Override
            public void onCompleted() {}
        };
        CancellationContext cancellationContext = new CancellationContext();
        observer.setCancellationContext(cancellationContext);
        observer.cancel(new IllegalStateException());
        Assertions.assertTrue(cancellationContext.isCancelled());
    }