diff --git a/src/workerd/api/cache.c++ b/src/workerd/api/cache.c++ index 68f394ce35a..6a978149b34 100644 --- a/src/workerd/api/cache.c++ +++ b/src/workerd/api/cache.c++ @@ -533,7 +533,7 @@ kj::Own Cache::getHttpClient( // ======================================================================================= // CacheStorage -CacheStorage::CacheStorage(): default_(jsg::alloc(nullptr)) {} +CacheStorage::CacheStorage(): default_(jsg::alloc(kj::none)) {} jsg::Promise> CacheStorage::open(jsg::Lock& js, kj::String cacheName) { // Set some reasonable limit to prevent scripts from blowing up our control header size. diff --git a/src/workerd/api/http.c++ b/src/workerd/api/http.c++ index 8a371457462..dee5c5113e5 100644 --- a/src/workerd/api/http.c++ +++ b/src/workerd/api/http.c++ @@ -1500,7 +1500,7 @@ jsg::Ref Response::redirect(jsg::Lock& js, kj::String url, jsg::Option auto statusText = defaultStatusText(statusCode); return jsg::alloc( - js, statusCode, kj::str(statusText), kj::mv(headers), nullptr, nullptr); + js, statusCode, kj::str(statusText), kj::mv(headers), nullptr, kj::none); } jsg::Ref Response::json_( @@ -2448,7 +2448,7 @@ jsg::Promise Fetcher::queue( auto encodedMessages = kj::heapArrayBuilder(messages.size()); for (auto& msg: messages) { KJ_IF_SOME(b, msg.body) { - JSG_REQUIRE(msg.serializedBody == nullptr, TypeError, + JSG_REQUIRE(msg.serializedBody == kj::none, TypeError, "Expected one of body or serializedBody for each message"); jsg::Serializer serializer(js, jsg::Serializer::Options{ diff --git a/src/workerd/api/sockets.c++ b/src/workerd/api/sockets.c++ index 2270f505a40..1efe981da3f 100644 --- a/src/workerd/api/sockets.c++ +++ b/src/workerd/api/sockets.c++ @@ -343,7 +343,7 @@ jsg::Ref Socket::startTls(jsg::Lock& js, jsg::Optional tlsOp // flush operation is taking a particularly long time (EW-8538), so we throw a JSG error if // that's the case. JSG_REQUIRE( - *tlsStarter != nullptr, TypeError, "The request has finished before startTls completed."); + *tlsStarter != kj::none, TypeError, "The request has finished before startTls completed."); auto secureStream = KJ_ASSERT_NONNULL(*tlsStarter)(acceptedHostname) .then([stream = connectionStream->addWrappedRef()]() mutable -> kj::Own { return kj::mv(stream); }); diff --git a/src/workerd/api/streams/standard.c++ b/src/workerd/api/streams/standard.c++ index 5ce0490860c..1589db0fca3 100644 --- a/src/workerd/api/streams/standard.c++ +++ b/src/workerd/api/streams/standard.c++ @@ -1278,8 +1278,8 @@ typename WritableImpl::WriteRequest WritableImpl::dequeueWriteReques template void WritableImpl::doClose(jsg::Lock& js) { - KJ_ASSERT(closeRequest == nullptr); - KJ_ASSERT(inFlightClose == nullptr); + KJ_ASSERT(closeRequest == kj::none); + KJ_ASSERT(inFlightClose == kj::none); KJ_ASSERT(inFlightWrite == kj::none); KJ_ASSERT(maybePendingAbort == kj::none); KJ_ASSERT(writeRequests.empty()); @@ -3855,9 +3855,9 @@ void TransformStreamDefaultController::init(jsg::Lock& js, // TODO(someday): The stream standard includes placeholders for supporting byte-oriented // TransformStreams but does not yet define them. For now, we are limiting our implementation // here to only support value-based transforms. - JSG_REQUIRE(transformer.readableType == nullptr, TypeError, + JSG_REQUIRE(transformer.readableType == kj::none, TypeError, "transformer.readableType must be undefined."); - JSG_REQUIRE(transformer.writableType == nullptr, TypeError, + JSG_REQUIRE(transformer.writableType == kj::none, TypeError, "transformer.writableType must be undefined."); KJ_IF_SOME(transform, transformer.transform) { diff --git a/src/workerd/api/web-socket.c++ b/src/workerd/api/web-socket.c++ index 6f943be8163..065a1bed9f2 100644 --- a/src/workerd/api/web-socket.c++ +++ b/src/workerd/api/web-socket.c++ @@ -625,7 +625,7 @@ void WebSocket::close(jsg::Lock& js, jsg::Optional code, jsg::Optional