PingResponseHandler implements ResponseHandler { @Override public void onRecord( Value[] fields ) { throw new UnsupportedOperationException(); } PingResponseHandler( Promise<Boolean> result, Channel channel, Logger log ); @Override void onSuccess( Map<String,Value> metadata ); @Override void onFailure( Throwable error ); @Override void onRecord( Value[] fields );  }
@Test void shouldNotSupportRecordMessages() { PingResponseHandler handler = newHandler( newPromise() ); assertThrows( UnsupportedOperationException.class, () -> handler.onRecord( new Value[0] ) ); }