ralf_boogie_blues(a)bluewin.ch wrote: Unfortunately it is fairly technical, as you need to provide a StreamSinkCoduit implementation that achieves this. These conduits support both blocking and non-blocking IO. The blocking side of things is fairly easy (if the data limit is exceeded just block for a while), however the non-blocking side of things is a bit more technical (basically when the limit is exceeded you return 0 and register a timer to notify the conduit when it can write again). Feel free to have ago at implementing this, or you can just file a JIRA and I will try and get to it some time this week. Stuart