The in-memory source operator can have messages injected into it via `testOnlyInsert`, but we don't enforce any limits on how many messages can be buffered. We want to limit the buffered messages by byte size and number of documents, such that once we hit those limits, all subsequent inserts should be blocking until the buffered messages are processed by the executor loop.