1 files changed, 10 insertions, 10 deletions
diff --git a/src/go/unit/nxt_go_lib.c b/src/go/unit/nxt_go_lib.c
index 84d64c0e..4c6b9ac2 100644
--- a/src/go/unit/nxt_go_lib.c
+++ b/src/go/unit/nxt_go_lib.c
@@ -112,18 +112,11 @@ nxt_go_request_done(nxt_go_request_t r)
 
 
 void
-nxt_go_ready()
+nxt_go_ready(uint32_t stream)
 {
-    char           *go_stream;
-    nxt_port_msg_t port_msg;
+    nxt_port_msg_t  port_msg;
 
-    go_stream = getenv("NXT_GO_STREAM");
-
-    if (go_stream == NULL) {
-        return;
-    }
-
-    port_msg.stream = atol(go_stream);
+    port_msg.stream = stream;
     port_msg.pid = getpid();
     port_msg.reply_port = 0;
     port_msg.type = _NXT_PORT_MSG_PROCESS_READY;
@@ -141,3 +134,10 @@ nxt_go_process_port_msg(uintptr_t buf, size_t buf_len, uintptr_t oob, size_t oob
 {
     return nxt_go_port_on_read((void *) buf, buf_len, (void *) oob, oob_len);
 }
+
+
+const char *
+nxt_go_version()
+{
+    return NXT_VERSION;
+}