Searched refs:NewMongoOpStream (Results 1 – 4 of 4) sorted by relevance
105 m := NewMongoOpStream(cfg.PacketBufSize)
137 func NewMongoOpStream(heapBufSize int) *MongoOpStream { func