diff --git a/counting_reader.zig b/counting_reader.zig
new file mode 100644
index 0000000000000000000000000000000000000000..33aa760145c94a28d391ce8699deb1ed56340202
--- /dev/null
+++ b/counting_reader.zig
@@ -0,0 +1,72 @@
+const std = @import("std");
+const builtin = @import("builtin");
+const extras = @import("extras");
+const nio = @import("./nio.zig");
+
+const sys = switch (builtin.target.os.tag) {
+    .linux => @import("sys-linux"),
+    .macos => @import("sys-darwin"),
+    else => unreachable,
+};
+
+pub fn CountingReader(ReaderType: type) type {
+    return struct {
+        backing_reader: ReaderType,
+        bytes_read: u64,
+
+        const Self = @This();
+
+        pub fn init(backing_reader: ReaderType) Self {
+            return .{
+                .backing_reader = backing_reader,
+                .bytes_read = 0,
+            };
+        }
+
+        const R = nio.Readable(@This(), ._var);
+        pub const readAll = R.readAll;
+        pub const readAtLeast = R.readAtLeast;
+        pub const readNoEof = R.readNoEof;
+        pub const readAllAlloc = R.readAllAlloc;
+        pub const readArray = R.readArray;
+        pub const readByte = R.readByte;
+        pub const readUntilDelimiterArrayList = R.readUntilDelimiterArrayList;
+        pub const readUntilDelimiterAlloc = R.readUntilDelimiterAlloc;
+        pub const readUntilDelimiterOrEofAlloc = R.readUntilDelimiterOrEofAlloc;
+        pub const readUntilDelimitersBuf = R.readUntilDelimitersBuf;
+        pub const readUntilDelimitersArrayList = R.readUntilDelimitersArrayList;
+        pub const readAlloc = R.readAlloc;
+        pub const readInt = R.readInt;
+        pub const readUntilDelimitersAlloc = R.readUntilDelimitersAlloc;
+        pub const readUntilDelimiterOrEof = R.readUntilDelimiterOrEof;
+        pub const readExpected = R.readExpected;
+        pub const skipBytes = R.skipBytes;
+        pub const skipUntilDelimiterOrEof = R.skipUntilDelimiterOrEof;
+
+        pub const ReadError = extras.Pointee(ReaderType).ReadError;
+
+        pub fn read(self: *Self, bytes: []u8) ReadError!usize {
+            const len = try self.backing_reader.read(bytes);
+            self.bytes_read += len;
+            return len;
+        }
+        // pub fn readv(self: *Self, iovec: []sys.struct_iovec) ReadError!usize {
+        //     const len = try self.backing_reader.readv(iovec);
+        //     self.bytes_read += len;
+        //     return len;
+        // }
+
+        pub fn anyReadable(self: *Self) nio.AnyReadable {
+            const S = struct {
+                fn read(s: *allowzero anyopaque, buffer: []u8) anyerror!usize {
+                    const fbs: *Self = @ptrCast(@alignCast(s));
+                    return fbs.read(buffer);
+                }
+            };
+            return .{
+                .vtable = &.{ .read = S.read },
+                .state = @ptrCast(self),
+            };
+        }
+    };
+}
diff --git a/nio.zig b/nio.zig
index 88f9e5502ccb214cc524a021a795e7482680e180..bdc922099b4aff719fd68c4a0807f091af4ee913 100644
--- a/nio.zig
+++ b/nio.zig
@@ -393,3 +393,5 @@ pub const CountingWriter = @import("./counting_writer.zig").CountingWriter;
 pub const NullWriter = @import("./null_writer.zig").NullWriter;
 
 pub const AllocatingWriter = @import("./allocating_writer.zig").AllocatingWriter;
+
+pub const CountingReader = @import("./counting_reader.zig").CountingReader;