code: @Override
      public void saveRDD(T t) {
          SaveAction<T> saveAction = new SaveAction<>(t);
  
          channel.writeAndFlush(saveAction);
  
          Response response;
          boolean interrupted = false;
          for (; ; ) {
              try {
                  response = answer.take();
                  break;
              } catch (InterruptedException ignore) {
                  interrupted = true;
              }
          }
  
          if (interrupted) {
              Thread.currentThread().interrupt();
          }
  
          return;
      }
docs: /*
  (non-Javadoc)
  
  @see com.stratio.deep.commons.rdd.IExtractor#saveRDD(java.lang.Object,
  com.stratio.deep.commons.functions.SaveFunction)