TODO: Move it to a common package (stream and socket use it).