Small fixes

This commit is contained in:
Christopher Schnick 2022-01-23 14:59:00 +01:00
parent fd4dcc0739
commit 41837479fc
3 changed files with 1 additions and 4 deletions

View file

@ -95,7 +95,6 @@ public class DataTableImpl extends DataSourceImpl implements DataTable {
performInputExchange(sc, req, (ReadTableDataExchange.Response res, InputStream in) -> {
var r = new TypedDataStreamParser(info.getDataType());
r.parseStructures(in, TypedDataStructureNodeReader.immutable(info.getDataType()), nodes::add);
return true;
});
}
}.execute();
@ -121,7 +120,6 @@ public class DataTableImpl extends DataSourceImpl implements DataTable {
performInputExchange(sc, req,
(ReadTableDataExchange.Response res, InputStream in) -> {
input = in;
return false;
});
}
}.execute();

View file

@ -27,7 +27,6 @@ public class StopExchange implements MessageExchange<StopExchange.Request, StopE
@Builder
@Value
public static class Request implements RequestMessage {
boolean force;
}
@Jacksonized

View file

@ -1,3 +1,3 @@
module io.xpipe.sample {
requires io.xpipe;
requires io.xpipe.api;
}