Method item

basex-api/src/main/java/org/basex/query/func/ws/WsEval.java:21–43

(final QueryContext qc, final InputInfo ii)

 */
public final class WsEval extends WsFn {
  @Override
  public Str item(final QueryContext qc, final InputInfo ii) throws QueryException {
    final IOContent query = toContent(arg(0), qc);
    final HashMap<String, Value> bindings = toBindings(arg(1), qc);
    final WsOptions options = toOptions(arg(2), new WsOptions(), qc);

    final JobOptions jopts = new JobOptions();
    jopts.set(JobOptions.BASE_URI, toBaseUri(query.url(), options, WsOptions.BASE_URI));
    jopts.set(JobOptions.ID, options.get(WsOptions.ID));

    final QueryJobSpec spec = new QueryJobSpec(jopts, bindings, query);
    final WebSocket ws = ws(qc);
    final Consumer<QueryJobResult> notify = result -> {
      try {
        WsPool.send(result.value, ws.id);
      } catch(final Exception ex) {
        ws.error(ex);
      }
    };

    final QueryJob job = new QueryJob(spec, qc.context, info, notify);
    return Str.get(job.jc().id());
  }
}