+static void test_client_fd_data_cb(struct ustream *s, int bytes)
+{
+ char *data, *sep;
+ int len;
+
+ data = ustream_get_read_buf(s, &len);
+ if (len < 1)
+ return;
+
+ sep = strchr(data, '\n');
+ if (!sep)
+ return;
+
+ *sep = 0;
+ fprintf(stderr, "Got line: %s\n", data);
+ ustream_consume(s, sep + 1 - data);
+}
+
+static void test_client_fd_cb(struct ubus_request *req, int fd)
+{
+ static struct ustream_fd test_fd;
+
+ fprintf(stderr, "Got fd from the server, watching...\n");
+
+ test_fd.stream.notify_read = test_client_fd_data_cb;
+ ustream_fd_init(&test_fd, fd);
+}
+
+static void test_client_complete_cb(struct ubus_request *req, int ret)
+{
+ fprintf(stderr, "completed request, ret: %d\n", ret);
+}
+