=str #15755 #15756 source and sink

sorry, deleted the old branch by accident, previous discussion was at #15786 
I am not sure about the crreunt rules anymore, but I think onSubscribe should fully return before you are allowed to call onNext -- i.e. no concurrent calls.