in playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/PlaygroundIngress.java [30:44]
public void run(SourceContext<T> sourceContext) throws Exception {
while (running) {
final AutoRoutable message = messageQueue.poll(50L, TimeUnit.MILLISECONDS);
if (message != null) {
synchronized (sourceContext.getCheckpointLock()) {
sourceContext.collect((T) message);
}
}
}
if (server != null) {
server.stop();
}
}