use a better primitive

Author: dylanvorster

packages/streaming/src/bson/decoder.ts

@@ -10,7 +10,7 @@ export type BSONStreamDecoderParams<T> = {
   writableStrategy?: QueuingStrategy<Buffer | undefined>;
   readableStrategy?: QueuingStrategy<T | undefined>;
 };
-export const createBSONStreamDecoder = <T = any>(params?: BSONStreamDecoderParams<T>): TransformStream<Buffer, T> => {
+export const createBSONStreamDecoder = <T = any>(params?: BSONStreamDecoderParams<T>): ReadableWritablePair<T,Buffer> => {
   const buffer = buffer_array.createReadableBufferArray();
   let frame_size: null | number = null;