The current implementation is using a blocking socket stream implementation. Would you accept a non-blocking implementation in your project? Do you have any criteria that I should meet for my contribution to be accepted?