diff --git a/src/core/Akka/Util/ByteString.cs b/src/core/Akka/Util/ByteString.cs index 5cf6d722fbf..72d724a361f 100644 --- a/src/core/Akka/Util/ByteString.cs +++ b/src/core/Akka/Util/ByteString.cs @@ -273,7 +273,12 @@ public override ByteIterator Iterator() _byteStrings.Select(x => (ByteIterator.ByteArrayIterator) x.Iterator()).ToArray()); } - public override ByteString Concat(ByteString that) + public override IEnumerator GetEnumerator() + { + return _byteStrings.SelectMany(byteString => byteString).GetEnumerator(); + } + + public override ByteString Concat(ByteString that) { if (that.IsEmpty) {