Support lambda flow for source models

Also rely on public API to detect the source node
This commit is contained in:
Benjamin Muskalla
2021-10-26 15:57:27 +02:00
parent 35baa1c3df
commit 9500c9c8bc
4 changed files with 38 additions and 22 deletions

View File

@@ -1 +1,3 @@
| p;Sources;true;readUrl;(URL);;ReturnValue;remote; |
| p;Sources;true;consumeSource;(int,Consumer);;Parameter[1];remote; |
| p;Sources;true;readUrl;(URL);;ReturnValue;remote; |
| p;Sources;true;socketStream;();;ReturnValue;remote; |

View File

@@ -2,7 +2,9 @@ package p;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.URL;
import java.util.function.Consumer;
public class Sources {
@@ -11,4 +13,13 @@ public class Sources {
return url.openConnection().getInputStream();
}
public InputStream socketStream() throws IOException {
ServerSocket socket = new ServerSocket(123);
return socket.accept().getInputStream();
}
public void consumeSource(int port, Consumer<InputStream> consumer) throws IOException {
ServerSocket socket = new ServerSocket(port);
consumer.accept(socket.accept().getInputStream());
}
}