+ GIOChannel* chan = g_io_channel_unix_new(0);
+ if(!chan) {
+ g_printerr("IO Channel could not be created.\n");
+ return 1;
+ }
+
+ GSource* src = g_io_create_watch(chan, G_IO_IN);
+
+ g_source_set_callback(src, (GSourceFunc)stdin_read, (gpointer)pipeline, NULL);
+ g_source_attach(src, ctx);
+