@Test
void shouldDelegateClose() throws Throwable
{

    // Given
    NetworkSession session = mock( NetworkSession.class );
    when( session.closeAsync() ).thenReturn( completedWithNull() );
    InternalRxSession rxSession = new InternalRxSession( session );
    // When
    Publisher<Void> mono = rxSession.close();
    // Then
    StepVerifier.create( mono ).verifyComplete();
    verify( session ).closeAsync();
    verifyNoMoreInteractions( session );
}