Fix assertions triggering for very small wait timeouts.
Cosmetics + add "in" contract for Timer.rearm.
Add ConnectionStream and let TCPConnection derive from it.
Implement pipeRealtime() for piping streams with realtime flushing of data.
Let TaskPipe derive from ConnectionStream and fix a possible hang in the read/write threads.