diff --git a/Scheduler/ReadHelper.ct b/Scheduler/ReadHelper.ct
index 40ac19936dcb6e2c31d470ddf1ac9a306eee0d6b..687a540539613b370864df071679adf3e97caf38 100644
--- a/Scheduler/ReadHelper.ct
+++ b/Scheduler/ReadHelper.ct
@@ -72,7 +72,8 @@ prefix_ void senf::ReadHelper<Handle>::process(Handle handle,
     try {
         if (event != senf::Scheduler::EV_READ)
             throw SystemException(EPIPE);
-        std::string rcv (handle.read(maxSize_ - data_.size()));
+        std::string rcv;
+        handle.read(rcv, maxSize_ - data_.size());
         data_.append(rcv);
         std::string::size_type n = predicate_ ? (*predicate_)(data_) : std::string::npos;
         if (n != std::string::npos || data_.size() >= maxSize_ || rcv.size() == 0) {
diff --git a/Scheduler/WriteHelper.ct b/Scheduler/WriteHelper.ct
index 9dfa7479367a818fafb89ffb6454b1de154b0b4c..6af5af862bdf9919ca6ec8e4f140150141682c88 100644
--- a/Scheduler/WriteHelper.ct
+++ b/Scheduler/WriteHelper.ct
@@ -35,7 +35,7 @@ template <class Handle>
 prefix_ senf::WriteHelper<Handle>::WriteHelper(Handle handle, std::string data,
                                                       Callback callback)
     : handle_(handle), data_(data), callback_(callback),
-      offset_(0), errno_(0)
+      offset_(data_.begin()), errno_(0)
 {
     senf::Scheduler::instance()
         .add(handle_, boost::bind(&WriteHelper::dispatchProcess, ptr(this), _1, _2),
@@ -46,9 +46,9 @@ template <class Handle>
 prefix_ std::string const & senf::WriteHelper<Handle>::data()
     const
 {
-    if (offset_ > 0) {
-        data_.erase(0,offset_);
-        offset_ = 0;
+    if (offset_ > data_.begin()) {
+        data_.erase(data_.begin(),offset_);
+        offset_ = data_.begin();
     }
     return data_;
 }
@@ -79,9 +79,10 @@ prefix_ void senf::WriteHelper<Handle>::process(Handle handle,
     try {
         if (event != senf::Scheduler::EV_WRITE)
             throw senf::SystemException(EPIPE);
-        offset_ += handle.write(data_.data()+offset_,data_.size()-offset_);
-        if (offset_ >= data_.size()) {
+        offset_ = handle.write(std::make_pair(offset_,data_.end()));
+        if (offset_ == data_.end()) {
             data_.erase();
+            offset_ = data_.begin();
             complete_ = true;
         }
     }
diff --git a/Scheduler/WriteHelper.hh b/Scheduler/WriteHelper.hh
index ccc2d26b051da411ec52bdd52d85274cb81e100d..7b4f0b436ff17d56ad6afdc30d61bb68bc89b0db 100644
--- a/Scheduler/WriteHelper.hh
+++ b/Scheduler/WriteHelper.hh
@@ -105,7 +105,7 @@ namespace senf {
         mutable std::string data_;
         Callback callback_;
 
-        mutable std::string::size_type offset_;
+        mutable std::string::iterator offset_;
         int errno_;
     };