diff --git a/src/core/ev.c b/src/core/ev.c
index d65c8c72..603d1496 100644
--- a/src/core/ev.c
+++ b/src/core/ev.c
@@ -789,7 +789,7 @@ JanetListenerState *janet_listen(JanetStream *stream, JanetListener behavior, in
         if (NULL == CreateIoCompletionPort(stream->handle, janet_vm_iocp, (ULONG_PTR) stream, 0)) {
             janet_panic("failed to listen for events");
         }
-        stream->flags |= JANET_POLL_FLAG_IOCP;
+        stream->flags |= JANET_STREAM_IOCP;
     }
     return state;
 }
diff --git a/src/include/janet.h b/src/include/janet.h
index fbfb7283..66fca887 100644
--- a/src/include/janet.h
+++ b/src/include/janet.h
@@ -502,7 +502,7 @@ typedef void *JanetAbstract;
 
 #define JANET_STREAM_CLOSED 0x1
 #define JANET_STREAM_SOCKET 0x2
-#define JANET_STREAM_ICOP 0x4
+#define JANET_STREAM_IOCP 0x4
 #define JANET_STREAM_READABLE 0x200
 #define JANET_STREAM_WRITABLE 0x400
 #define JANET_STREAM_ACCEPTABLE 0x800