CLEANUP: Remove the 'from-dispatcher-to-parent' file communication channel

Author: HenrikBengtsson

DESCRIPTION

@@ -1,6 +1,6 @@
 Package: future.p2p
 Title: A Peer-to-Peer Compute Cluster via Futureverse
-Version: 0.3.0-9023
+Version: 0.3.0-9024
 Description: Implementation of the 'Future' API <doi:10.32614/RJ-2021-048> that resolves futures on a peer-to-peer ('P2P') compute environment. By using this future backend, you and your friends can share your spare compute resources with each other.
 Imports:
     future (>= 1.67.0),

R/pico_p2p.R

@@ -340,10 +340,8 @@ pico_p2p_hosted_clusters <- function(host = "pipe.pico.sh", ssh_args = NULL, tim
 pico_p2p_dispatch_future <- function(future) {
   send_future <- function(topic, name, host = host, ssh_args = ssh_args, future_id, file, to, via, duration, channels, debug = FALSE) {
     update_parent <- function(msg, ...) {
-      rx <- channels[["rx"]]
-      if (is.null(rx)) return()
       cat(sprintf("dispatcher_status=%s\n", msg), file = stdout())
-      flush.connection(stdout())
+      flush(stdout())
     }
 
     listen_parent <- function(...) {
@@ -489,8 +487,7 @@ pico_p2p_dispatch_future <- function(future) {
   future_id <- future_id(future)
   channel_prefix <- sprintf("%s_%s", .packageName, future_id)
   channels <- c(
-    tx = tempfile(pattern = channel_prefix, fileext = ".tx"),
-    rx = tempfile(pattern = channel_prefix, fileext = ".rx")
+    tx = tempfile(pattern = channel_prefix, fileext = ".tx")
   )
   lapply(channels, FUN = file.create, showWarnings = FALSE)