Remove basic support for lambda flow

This commit is contained in:
Benjamin Muskalla
2021-11-15 12:38:30 +01:00
parent 78e3906ea7
commit bca6cecd1c
3 changed files with 2 additions and 25 deletions

View File

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

View File

@@ -18,8 +18,4 @@ public class Sources {
return socket.accept().getInputStream();
}
public void consumeSource(int port, Consumer<InputStream> consumer) throws IOException {
ServerSocket socket = new ServerSocket(port);
consumer.accept(socket.accept().getInputStream());
}
}