app,worker: use close(quit) to broadcast end of event processing
io: first stab
io: first stab at a concrete InputStream
io: extend ioStreamer ifaces