diff --git a/lib/src/insertable_streams/TODO.md b/lib/src/insertable_streams/TODO.md new file mode 100644 index 0000000..330a42d --- /dev/null +++ b/lib/src/insertable_streams/TODO.md @@ -0,0 +1,3 @@ +# TODO + +* RTCRtpSender.createEncodedStreams diff --git a/lib/src/insertable_streams/audio_data.dart b/lib/src/insertable_streams/audio_data.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/data_view.dart b/lib/src/insertable_streams/data_view.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/encoded_audio_chunk.dart b/lib/src/insertable_streams/encoded_audio_chunk.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/encoded_video_chunk.dart b/lib/src/insertable_streams/encoded_video_chunk.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/media_stream_track_generator.dart b/lib/src/insertable_streams/media_stream_track_generator.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/media_stream_track_processor.dart b/lib/src/insertable_streams/media_stream_track_processor.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/optional.dart b/lib/src/insertable_streams/optional.dart new file mode 100644 index 0000000..706a872 --- /dev/null +++ b/lib/src/insertable_streams/optional.dart @@ -0,0 +1 @@ +class Optional {} diff --git a/lib/src/insertable_streams/readable_stream.dart b/lib/src/insertable_streams/readable_stream.dart new file mode 100644 index 0000000..90d2f53 --- /dev/null +++ b/lib/src/insertable_streams/readable_stream.dart @@ -0,0 +1,18 @@ +import 'optional.dart'; +import 'readable_stream_default_reader.dart'; +import 'transform_stream.dart'; +import 'writable_stream.dart'; + +class ReadableStream { + bool locked = true; + void cancel() {} + void pipeThrough(TransformStream sink, [Optional? optional]) => + throw UnimplementedError(); + + void pipeTo(WritableStream sink, [Optional? optional]) => + throw UnimplementedError(); + + ReadableStreamDefaultReader getReader() => throw UnimplementedError(); + + Future tee() => throw UnimplementedError(); +} diff --git a/lib/src/insertable_streams/readable_stream_default_reader.dart b/lib/src/insertable_streams/readable_stream_default_reader.dart new file mode 100644 index 0000000..bff38bf --- /dev/null +++ b/lib/src/insertable_streams/readable_stream_default_reader.dart @@ -0,0 +1,13 @@ +abstract class ReadableStreamDefaultReader { + late bool closed; + + late int desiredSize; + + void abort(); + + void close(); + + void releaseLock(); + + void read(Function(bool done, dynamic value) chunkHandler); +} diff --git a/lib/src/insertable_streams/transform_stream.dart b/lib/src/insertable_streams/transform_stream.dart new file mode 100644 index 0000000..35fe084 --- /dev/null +++ b/lib/src/insertable_streams/transform_stream.dart @@ -0,0 +1,15 @@ +import 'readable_stream.dart'; +import 'writable_stream.dart'; + +class TransformStream { + TransformStream(this.readable, this.writable); + factory TransformStream.clone(TransformStream transformer) { + return transformer._cloneInternal(); + } + TransformStream _cloneInternal() { + throw UnimplementedError(); + } + + ReadableStream readable; + WritableStream writable; +} diff --git a/lib/src/insertable_streams/transform_stream_default_controller.dart b/lib/src/insertable_streams/transform_stream_default_controller.dart new file mode 100644 index 0000000..a592fd7 --- /dev/null +++ b/lib/src/insertable_streams/transform_stream_default_controller.dart @@ -0,0 +1,9 @@ +abstract class TransformStreamDefaultController { + int desiredSize = 0; + + void enqueue(chunk); + + void error(reason); + + void terminate(); +} diff --git a/lib/src/insertable_streams/video_frame.dart b/lib/src/insertable_streams/video_frame.dart new file mode 100644 index 0000000..e69de29 diff --git a/lib/src/insertable_streams/writable_stream.dart b/lib/src/insertable_streams/writable_stream.dart new file mode 100644 index 0000000..7afa0ce --- /dev/null +++ b/lib/src/insertable_streams/writable_stream.dart @@ -0,0 +1,8 @@ +import 'writable_stream_default_writer.dart'; + +class WritableStream { + bool locked = true; + void abort() => throw UnimplementedError(); + void close() => throw UnimplementedError(); + WritableStreamDefaultWriter getWriter() => throw UnimplementedError(); +} diff --git a/lib/src/insertable_streams/writable_stream_default_writer.dart b/lib/src/insertable_streams/writable_stream_default_writer.dart new file mode 100644 index 0000000..d4f26d1 --- /dev/null +++ b/lib/src/insertable_streams/writable_stream_default_writer.dart @@ -0,0 +1,13 @@ +abstract class WritableStreamDefaultWriter { + late bool closed; + + late int desiredSize; + + void abort(); + + void close(); + + void releaseLock(); + + void write(chunk); +}