| Index: mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
|
| diff --git a/mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
|
| similarity index 55%
|
| copy from mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.mojom.dart
|
| copy to mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
|
| index 35dd6559aff4167bc8bb5923a5bb4f7947832368..507df9fbcadc7d01abe87979553a839207e3d92a 100644
|
| --- a/mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.mojom.dart
|
| +++ b/mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
|
| @@ -2,116 +2,27 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -library sample_factory_mojom;
|
| +library media_transport_mojom;
|
|
|
| import 'dart:async';
|
|
|
| import 'package:mojo/bindings.dart' as bindings;
|
| import 'package:mojo/core.dart' as core;
|
| -import 'package:_mojo_for_test_only/imported/sample_import.mojom.dart' as sample_import_mojom;
|
| +import 'package:mojo_services/mojo/media/media_common.mojom.dart' as media_common_mojom;
|
| +import 'package:mojo_services/mojo/media/media_pipe.mojom.dart' as media_pipe_mojom;
|
| +import 'package:mojo_services/mojo/media/media_types.mojom.dart' as media_types_mojom;
|
|
|
|
|
|
|
| -class Request extends bindings.Struct {
|
| - static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(32, 0)
|
| - ];
|
| - int x = 0;
|
| - core.MojoMessagePipeEndpoint pipe = null;
|
| - List<core.MojoMessagePipeEndpoint> morePipes = null;
|
| - Object obj = null;
|
| -
|
| - Request() : super(kVersions.last.size);
|
| -
|
| - static Request deserialize(bindings.Message message) {
|
| - var decoder = new bindings.Decoder(message);
|
| - var result = decode(decoder);
|
| - if (decoder.excessHandles != null) {
|
| - decoder.excessHandles.forEach((h) => h.close());
|
| - }
|
| - return result;
|
| - }
|
| -
|
| - static Request decode(bindings.Decoder decoder0) {
|
| - if (decoder0 == null) {
|
| - return null;
|
| - }
|
| - Request result = new Request();
|
| -
|
| - var mainDataHeader = decoder0.decodeStructDataHeader();
|
| - if (mainDataHeader.version <= kVersions.last.version) {
|
| - // Scan in reverse order to optimize for more recent versions.
|
| - for (int i = kVersions.length - 1; i >= 0; --i) {
|
| - if (mainDataHeader.version >= kVersions[i].version) {
|
| - if (mainDataHeader.size == kVersions[i].size) {
|
| - // Found a match.
|
| - break;
|
| - }
|
| - throw new bindings.MojoCodecError(
|
| - 'Header size doesn\'t correspond to known version size.');
|
| - }
|
| - }
|
| - } else if (mainDataHeader.size < kVersions.last.size) {
|
| - throw new bindings.MojoCodecError(
|
| - 'Message newer than the last known version cannot be shorter than '
|
| - 'required by the last known version.');
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.x = decoder0.decodeInt32(8);
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.pipe = decoder0.decodeMessagePipeHandle(12, true);
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.morePipes = decoder0.decodeMessagePipeHandleArray(16, bindings.kArrayNullable, bindings.kUnspecifiedArrayLength);
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.obj = decoder0.decodeServiceInterface(24, true, sample_import_mojom.ImportedInterfaceProxy.newFromEndpoint);
|
| - }
|
| - return result;
|
| - }
|
| -
|
| - void encode(bindings.Encoder encoder) {
|
| - var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
| -
|
| - encoder0.encodeInt32(x, 8);
|
| -
|
| - encoder0.encodeMessagePipeHandle(pipe, 12, true);
|
| -
|
| - encoder0.encodeMessagePipeHandleArray(morePipes, 16, bindings.kArrayNullable, bindings.kUnspecifiedArrayLength);
|
| -
|
| - encoder0.encodeInterface(obj, 24, true);
|
| - }
|
| -
|
| - String toString() {
|
| - return "Request("
|
| - "x: $x" ", "
|
| - "pipe: $pipe" ", "
|
| - "morePipes: $morePipes" ", "
|
| - "obj: $obj" ")";
|
| - }
|
| -
|
| - Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| - }
|
| -}
|
| -
|
| -
|
| -class Response extends bindings.Struct {
|
| +class _MediaProducerConnectParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| const bindings.StructDataHeader(16, 0)
|
| ];
|
| - int x = 0;
|
| - core.MojoMessagePipeEndpoint pipe = null;
|
| + Object consumer = null;
|
|
|
| - Response() : super(kVersions.last.size);
|
| + _MediaProducerConnectParams() : super(kVersions.last.size);
|
|
|
| - static Response deserialize(bindings.Message message) {
|
| + static _MediaProducerConnectParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -120,11 +31,11 @@ class Response extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static Response decode(bindings.Decoder decoder0) {
|
| + static _MediaProducerConnectParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - Response result = new Response();
|
| + _MediaProducerConnectParams result = new _MediaProducerConnectParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -146,11 +57,7 @@ class Response extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - result.x = decoder0.decodeInt32(8);
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.pipe = decoder0.decodeMessagePipeHandle(12, true);
|
| + result.consumer = decoder0.decodeServiceInterface(8, false, MediaConsumerProxy.newFromEndpoint);
|
| }
|
| return result;
|
| }
|
| @@ -158,15 +65,12 @@ class Response extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeInt32(x, 8);
|
| -
|
| - encoder0.encodeMessagePipeHandle(pipe, 12, true);
|
| + encoder0.encodeInterface(consumer, 8, false);
|
| }
|
|
|
| String toString() {
|
| - return "Response("
|
| - "x: $x" ", "
|
| - "pipe: $pipe" ")";
|
| + return "_MediaProducerConnectParams("
|
| + "consumer: $consumer" ")";
|
| }
|
|
|
| Map toJson() {
|
| @@ -176,15 +80,14 @@ class Response extends bindings.Struct {
|
| }
|
|
|
|
|
| -class _NamedObjectSetNameParams extends bindings.Struct {
|
| +class MediaProducerConnectResponseParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(16, 0)
|
| + const bindings.StructDataHeader(8, 0)
|
| ];
|
| - String name = null;
|
|
|
| - _NamedObjectSetNameParams() : super(kVersions.last.size);
|
| + MediaProducerConnectResponseParams() : super(kVersions.last.size);
|
|
|
| - static _NamedObjectSetNameParams deserialize(bindings.Message message) {
|
| + static MediaProducerConnectResponseParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -193,11 +96,11 @@ class _NamedObjectSetNameParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static _NamedObjectSetNameParams decode(bindings.Decoder decoder0) {
|
| + static MediaProducerConnectResponseParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - _NamedObjectSetNameParams result = new _NamedObjectSetNameParams();
|
| + MediaProducerConnectResponseParams result = new MediaProducerConnectResponseParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -217,40 +120,32 @@ class _NamedObjectSetNameParams extends bindings.Struct {
|
| 'Message newer than the last known version cannot be shorter than '
|
| 'required by the last known version.');
|
| }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.name = decoder0.decodeString(8, false);
|
| - }
|
| return result;
|
| }
|
|
|
| void encode(bindings.Encoder encoder) {
|
| - var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
| -
|
| - encoder0.encodeString(name, 8, false);
|
| + encoder.getStructEncoderAtOffset(kVersions.last);
|
| }
|
|
|
| String toString() {
|
| - return "_NamedObjectSetNameParams("
|
| - "name: $name" ")";
|
| + return "MediaProducerConnectResponseParams("")";
|
| }
|
|
|
| Map toJson() {
|
| Map map = new Map();
|
| - map["name"] = name;
|
| return map;
|
| }
|
| }
|
|
|
|
|
| -class _NamedObjectGetNameParams extends bindings.Struct {
|
| +class _MediaProducerDisconnectParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| const bindings.StructDataHeader(8, 0)
|
| ];
|
|
|
| - _NamedObjectGetNameParams() : super(kVersions.last.size);
|
| + _MediaProducerDisconnectParams() : super(kVersions.last.size);
|
|
|
| - static _NamedObjectGetNameParams deserialize(bindings.Message message) {
|
| + static _MediaProducerDisconnectParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -259,11 +154,11 @@ class _NamedObjectGetNameParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static _NamedObjectGetNameParams decode(bindings.Decoder decoder0) {
|
| + static _MediaProducerDisconnectParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - _NamedObjectGetNameParams result = new _NamedObjectGetNameParams();
|
| + _MediaProducerDisconnectParams result = new _MediaProducerDisconnectParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -291,7 +186,7 @@ class _NamedObjectGetNameParams extends bindings.Struct {
|
| }
|
|
|
| String toString() {
|
| - return "_NamedObjectGetNameParams("")";
|
| + return "_MediaProducerDisconnectParams("")";
|
| }
|
|
|
| Map toJson() {
|
| @@ -301,15 +196,14 @@ class _NamedObjectGetNameParams extends bindings.Struct {
|
| }
|
|
|
|
|
| -class NamedObjectGetNameResponseParams extends bindings.Struct {
|
| +class _MediaPullModeProducerGetBufferParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(16, 0)
|
| + const bindings.StructDataHeader(8, 0)
|
| ];
|
| - String name = null;
|
|
|
| - NamedObjectGetNameResponseParams() : super(kVersions.last.size);
|
| + _MediaPullModeProducerGetBufferParams() : super(kVersions.last.size);
|
|
|
| - static NamedObjectGetNameResponseParams deserialize(bindings.Message message) {
|
| + static _MediaPullModeProducerGetBufferParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -318,11 +212,11 @@ class NamedObjectGetNameResponseParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static NamedObjectGetNameResponseParams decode(bindings.Decoder decoder0) {
|
| + static _MediaPullModeProducerGetBufferParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - NamedObjectGetNameResponseParams result = new NamedObjectGetNameResponseParams();
|
| + _MediaPullModeProducerGetBufferParams result = new _MediaPullModeProducerGetBufferParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -342,42 +236,33 @@ class NamedObjectGetNameResponseParams extends bindings.Struct {
|
| 'Message newer than the last known version cannot be shorter than '
|
| 'required by the last known version.');
|
| }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.name = decoder0.decodeString(8, false);
|
| - }
|
| return result;
|
| }
|
|
|
| void encode(bindings.Encoder encoder) {
|
| - var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
| -
|
| - encoder0.encodeString(name, 8, false);
|
| + encoder.getStructEncoderAtOffset(kVersions.last);
|
| }
|
|
|
| String toString() {
|
| - return "NamedObjectGetNameResponseParams("
|
| - "name: $name" ")";
|
| + return "_MediaPullModeProducerGetBufferParams("")";
|
| }
|
|
|
| Map toJson() {
|
| Map map = new Map();
|
| - map["name"] = name;
|
| return map;
|
| }
|
| }
|
|
|
|
|
| -class _FactoryDoStuffParams extends bindings.Struct {
|
| +class MediaPullModeProducerGetBufferResponseParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(24, 0)
|
| + const bindings.StructDataHeader(16, 0)
|
| ];
|
| - Request request = null;
|
| - core.MojoMessagePipeEndpoint pipe = null;
|
| + core.MojoSharedBuffer buffer = null;
|
|
|
| - _FactoryDoStuffParams() : super(kVersions.last.size);
|
| + MediaPullModeProducerGetBufferResponseParams() : super(kVersions.last.size);
|
|
|
| - static _FactoryDoStuffParams deserialize(bindings.Message message) {
|
| + static MediaPullModeProducerGetBufferResponseParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -386,11 +271,11 @@ class _FactoryDoStuffParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static _FactoryDoStuffParams decode(bindings.Decoder decoder0) {
|
| + static MediaPullModeProducerGetBufferResponseParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - _FactoryDoStuffParams result = new _FactoryDoStuffParams();
|
| + MediaPullModeProducerGetBufferResponseParams result = new MediaPullModeProducerGetBufferResponseParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -412,12 +297,7 @@ class _FactoryDoStuffParams extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - var decoder1 = decoder0.decodePointer(8, false);
|
| - result.request = Request.decode(decoder1);
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.pipe = decoder0.decodeMessagePipeHandle(16, true);
|
| + result.buffer = decoder0.decodeSharedBufferHandle(8, false);
|
| }
|
| return result;
|
| }
|
| @@ -425,15 +305,12 @@ class _FactoryDoStuffParams extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeStruct(request, 8, false);
|
| -
|
| - encoder0.encodeMessagePipeHandle(pipe, 16, true);
|
| + encoder0.encodeSharedBufferHandle(buffer, 8, false);
|
| }
|
|
|
| String toString() {
|
| - return "_FactoryDoStuffParams("
|
| - "request: $request" ", "
|
| - "pipe: $pipe" ")";
|
| + return "MediaPullModeProducerGetBufferResponseParams("
|
| + "buffer: $buffer" ")";
|
| }
|
|
|
| Map toJson() {
|
| @@ -443,16 +320,15 @@ class _FactoryDoStuffParams extends bindings.Struct {
|
| }
|
|
|
|
|
| -class FactoryDoStuffResponseParams extends bindings.Struct {
|
| +class _MediaPullModeProducerPullPacketParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(24, 0)
|
| + const bindings.StructDataHeader(16, 0)
|
| ];
|
| - Response response = null;
|
| - String text = null;
|
| + media_pipe_mojom.MediaPacket toRelease = null;
|
|
|
| - FactoryDoStuffResponseParams() : super(kVersions.last.size);
|
| + _MediaPullModeProducerPullPacketParams() : super(kVersions.last.size);
|
|
|
| - static FactoryDoStuffResponseParams deserialize(bindings.Message message) {
|
| + static _MediaPullModeProducerPullPacketParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -461,11 +337,11 @@ class FactoryDoStuffResponseParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static FactoryDoStuffResponseParams decode(bindings.Decoder decoder0) {
|
| + static _MediaPullModeProducerPullPacketParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - FactoryDoStuffResponseParams result = new FactoryDoStuffResponseParams();
|
| + _MediaPullModeProducerPullPacketParams result = new _MediaPullModeProducerPullPacketParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -487,12 +363,8 @@ class FactoryDoStuffResponseParams extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - var decoder1 = decoder0.decodePointer(8, false);
|
| - result.response = Response.decode(decoder1);
|
| - }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.text = decoder0.decodeString(16, false);
|
| + var decoder1 = decoder0.decodePointer(8, true);
|
| + result.toRelease = media_pipe_mojom.MediaPacket.decode(decoder1);
|
| }
|
| return result;
|
| }
|
| @@ -500,33 +372,31 @@ class FactoryDoStuffResponseParams extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeStruct(response, 8, false);
|
| -
|
| - encoder0.encodeString(text, 16, false);
|
| + encoder0.encodeStruct(toRelease, 8, true);
|
| }
|
|
|
| String toString() {
|
| - return "FactoryDoStuffResponseParams("
|
| - "response: $response" ", "
|
| - "text: $text" ")";
|
| + return "_MediaPullModeProducerPullPacketParams("
|
| + "toRelease: $toRelease" ")";
|
| }
|
|
|
| Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| + Map map = new Map();
|
| + map["toRelease"] = toRelease;
|
| + return map;
|
| }
|
| }
|
|
|
|
|
| -class _FactoryDoStuff2Params extends bindings.Struct {
|
| +class MediaPullModeProducerPullPacketResponseParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| const bindings.StructDataHeader(16, 0)
|
| ];
|
| - core.MojoDataPipeConsumer pipe = null;
|
| + media_pipe_mojom.MediaPacket packet = null;
|
|
|
| - _FactoryDoStuff2Params() : super(kVersions.last.size);
|
| + MediaPullModeProducerPullPacketResponseParams() : super(kVersions.last.size);
|
|
|
| - static _FactoryDoStuff2Params deserialize(bindings.Message message) {
|
| + static MediaPullModeProducerPullPacketResponseParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -535,11 +405,11 @@ class _FactoryDoStuff2Params extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static _FactoryDoStuff2Params decode(bindings.Decoder decoder0) {
|
| + static MediaPullModeProducerPullPacketResponseParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - _FactoryDoStuff2Params result = new _FactoryDoStuff2Params();
|
| + MediaPullModeProducerPullPacketResponseParams result = new MediaPullModeProducerPullPacketResponseParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -561,7 +431,8 @@ class _FactoryDoStuff2Params extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - result.pipe = decoder0.decodeConsumerHandle(8, false);
|
| + var decoder1 = decoder0.decodePointer(8, false);
|
| + result.packet = media_pipe_mojom.MediaPacket.decode(decoder1);
|
| }
|
| return result;
|
| }
|
| @@ -569,30 +440,31 @@ class _FactoryDoStuff2Params extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeConsumerHandle(pipe, 8, false);
|
| + encoder0.encodeStruct(packet, 8, false);
|
| }
|
|
|
| String toString() {
|
| - return "_FactoryDoStuff2Params("
|
| - "pipe: $pipe" ")";
|
| + return "MediaPullModeProducerPullPacketResponseParams("
|
| + "packet: $packet" ")";
|
| }
|
|
|
| Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| + Map map = new Map();
|
| + map["packet"] = packet;
|
| + return map;
|
| }
|
| }
|
|
|
|
|
| -class FactoryDoStuff2ResponseParams extends bindings.Struct {
|
| +class _MediaPullModeProducerReleasePacketParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| const bindings.StructDataHeader(16, 0)
|
| ];
|
| - String text = null;
|
| + media_pipe_mojom.MediaPacket toRelease = null;
|
|
|
| - FactoryDoStuff2ResponseParams() : super(kVersions.last.size);
|
| + _MediaPullModeProducerReleasePacketParams() : super(kVersions.last.size);
|
|
|
| - static FactoryDoStuff2ResponseParams deserialize(bindings.Message message) {
|
| + static _MediaPullModeProducerReleasePacketParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -601,11 +473,11 @@ class FactoryDoStuff2ResponseParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static FactoryDoStuff2ResponseParams decode(bindings.Decoder decoder0) {
|
| + static _MediaPullModeProducerReleasePacketParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - FactoryDoStuff2ResponseParams result = new FactoryDoStuff2ResponseParams();
|
| + _MediaPullModeProducerReleasePacketParams result = new _MediaPullModeProducerReleasePacketParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -627,7 +499,8 @@ class FactoryDoStuff2ResponseParams extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - result.text = decoder0.decodeString(8, false);
|
| + var decoder1 = decoder0.decodePointer(8, false);
|
| + result.toRelease = media_pipe_mojom.MediaPacket.decode(decoder1);
|
| }
|
| return result;
|
| }
|
| @@ -635,31 +508,32 @@ class FactoryDoStuff2ResponseParams extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeString(text, 8, false);
|
| + encoder0.encodeStruct(toRelease, 8, false);
|
| }
|
|
|
| String toString() {
|
| - return "FactoryDoStuff2ResponseParams("
|
| - "text: $text" ")";
|
| + return "_MediaPullModeProducerReleasePacketParams("
|
| + "toRelease: $toRelease" ")";
|
| }
|
|
|
| Map toJson() {
|
| Map map = new Map();
|
| - map["text"] = text;
|
| + map["toRelease"] = toRelease;
|
| return map;
|
| }
|
| }
|
|
|
|
|
| -class _FactoryCreateNamedObjectParams extends bindings.Struct {
|
| +class _MediaConsumerSetBufferParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(16, 0)
|
| + const bindings.StructDataHeader(24, 0)
|
| ];
|
| - Object obj = null;
|
| + core.MojoSharedBuffer buffer = null;
|
| + int size = 0;
|
|
|
| - _FactoryCreateNamedObjectParams() : super(kVersions.last.size);
|
| + _MediaConsumerSetBufferParams() : super(kVersions.last.size);
|
|
|
| - static _FactoryCreateNamedObjectParams deserialize(bindings.Message message) {
|
| + static _MediaConsumerSetBufferParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -668,11 +542,11 @@ class _FactoryCreateNamedObjectParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static _FactoryCreateNamedObjectParams decode(bindings.Decoder decoder0) {
|
| + static _MediaConsumerSetBufferParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - _FactoryCreateNamedObjectParams result = new _FactoryCreateNamedObjectParams();
|
| + _MediaConsumerSetBufferParams result = new _MediaConsumerSetBufferParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -694,73 +568,11 @@ class _FactoryCreateNamedObjectParams extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - result.obj = decoder0.decodeInterfaceRequest(8, false, NamedObjectStub.newFromEndpoint);
|
| - }
|
| - return result;
|
| - }
|
| -
|
| - void encode(bindings.Encoder encoder) {
|
| - var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
| -
|
| - encoder0.encodeInterfaceRequest(obj, 8, false);
|
| - }
|
| -
|
| - String toString() {
|
| - return "_FactoryCreateNamedObjectParams("
|
| - "obj: $obj" ")";
|
| - }
|
| -
|
| - Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| - }
|
| -}
|
| -
|
| -
|
| -class _FactoryRequestImportedInterfaceParams extends bindings.Struct {
|
| - static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(16, 0)
|
| - ];
|
| - Object obj = null;
|
| -
|
| - _FactoryRequestImportedInterfaceParams() : super(kVersions.last.size);
|
| -
|
| - static _FactoryRequestImportedInterfaceParams deserialize(bindings.Message message) {
|
| - var decoder = new bindings.Decoder(message);
|
| - var result = decode(decoder);
|
| - if (decoder.excessHandles != null) {
|
| - decoder.excessHandles.forEach((h) => h.close());
|
| - }
|
| - return result;
|
| - }
|
| -
|
| - static _FactoryRequestImportedInterfaceParams decode(bindings.Decoder decoder0) {
|
| - if (decoder0 == null) {
|
| - return null;
|
| - }
|
| - _FactoryRequestImportedInterfaceParams result = new _FactoryRequestImportedInterfaceParams();
|
| -
|
| - var mainDataHeader = decoder0.decodeStructDataHeader();
|
| - if (mainDataHeader.version <= kVersions.last.version) {
|
| - // Scan in reverse order to optimize for more recent versions.
|
| - for (int i = kVersions.length - 1; i >= 0; --i) {
|
| - if (mainDataHeader.version >= kVersions[i].version) {
|
| - if (mainDataHeader.size == kVersions[i].size) {
|
| - // Found a match.
|
| - break;
|
| - }
|
| - throw new bindings.MojoCodecError(
|
| - 'Header size doesn\'t correspond to known version size.');
|
| - }
|
| - }
|
| - } else if (mainDataHeader.size < kVersions.last.size) {
|
| - throw new bindings.MojoCodecError(
|
| - 'Message newer than the last known version cannot be shorter than '
|
| - 'required by the last known version.');
|
| + result.buffer = decoder0.decodeSharedBufferHandle(8, false);
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - result.obj = decoder0.decodeInterfaceRequest(8, false, sample_import_mojom.ImportedInterfaceStub.newFromEndpoint);
|
| + result.size = decoder0.decodeUint64(16);
|
| }
|
| return result;
|
| }
|
| @@ -768,12 +580,15 @@ class _FactoryRequestImportedInterfaceParams extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeInterfaceRequest(obj, 8, false);
|
| + encoder0.encodeSharedBufferHandle(buffer, 8, false);
|
| +
|
| + encoder0.encodeUint64(size, 16);
|
| }
|
|
|
| String toString() {
|
| - return "_FactoryRequestImportedInterfaceParams("
|
| - "obj: $obj" ")";
|
| + return "_MediaConsumerSetBufferParams("
|
| + "buffer: $buffer" ", "
|
| + "size: $size" ")";
|
| }
|
|
|
| Map toJson() {
|
| @@ -783,15 +598,14 @@ class _FactoryRequestImportedInterfaceParams extends bindings.Struct {
|
| }
|
|
|
|
|
| -class FactoryRequestImportedInterfaceResponseParams extends bindings.Struct {
|
| +class MediaConsumerSetBufferResponseParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(16, 0)
|
| + const bindings.StructDataHeader(8, 0)
|
| ];
|
| - Object obj = null;
|
|
|
| - FactoryRequestImportedInterfaceResponseParams() : super(kVersions.last.size);
|
| + MediaConsumerSetBufferResponseParams() : super(kVersions.last.size);
|
|
|
| - static FactoryRequestImportedInterfaceResponseParams deserialize(bindings.Message message) {
|
| + static MediaConsumerSetBufferResponseParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -800,11 +614,11 @@ class FactoryRequestImportedInterfaceResponseParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static FactoryRequestImportedInterfaceResponseParams decode(bindings.Decoder decoder0) {
|
| + static MediaConsumerSetBufferResponseParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - FactoryRequestImportedInterfaceResponseParams result = new FactoryRequestImportedInterfaceResponseParams();
|
| + MediaConsumerSetBufferResponseParams result = new MediaConsumerSetBufferResponseParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -824,40 +638,33 @@ class FactoryRequestImportedInterfaceResponseParams extends bindings.Struct {
|
| 'Message newer than the last known version cannot be shorter than '
|
| 'required by the last known version.');
|
| }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.obj = decoder0.decodeInterfaceRequest(8, false, sample_import_mojom.ImportedInterfaceStub.newFromEndpoint);
|
| - }
|
| return result;
|
| }
|
|
|
| void encode(bindings.Encoder encoder) {
|
| - var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
| -
|
| - encoder0.encodeInterfaceRequest(obj, 8, false);
|
| + encoder.getStructEncoderAtOffset(kVersions.last);
|
| }
|
|
|
| String toString() {
|
| - return "FactoryRequestImportedInterfaceResponseParams("
|
| - "obj: $obj" ")";
|
| + return "MediaConsumerSetBufferResponseParams("")";
|
| }
|
|
|
| Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| + Map map = new Map();
|
| + return map;
|
| }
|
| }
|
|
|
|
|
| -class _FactoryTakeImportedInterfaceParams extends bindings.Struct {
|
| +class _MediaConsumerPushPacketParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| const bindings.StructDataHeader(16, 0)
|
| ];
|
| - Object obj = null;
|
| + media_pipe_mojom.MediaPacket packet = null;
|
|
|
| - _FactoryTakeImportedInterfaceParams() : super(kVersions.last.size);
|
| + _MediaConsumerPushPacketParams() : super(kVersions.last.size);
|
|
|
| - static _FactoryTakeImportedInterfaceParams deserialize(bindings.Message message) {
|
| + static _MediaConsumerPushPacketParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -866,11 +673,11 @@ class _FactoryTakeImportedInterfaceParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static _FactoryTakeImportedInterfaceParams decode(bindings.Decoder decoder0) {
|
| + static _MediaConsumerPushPacketParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - _FactoryTakeImportedInterfaceParams result = new _FactoryTakeImportedInterfaceParams();
|
| + _MediaConsumerPushPacketParams result = new _MediaConsumerPushPacketParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -892,7 +699,8 @@ class _FactoryTakeImportedInterfaceParams extends bindings.Struct {
|
| }
|
| if (mainDataHeader.version >= 0) {
|
|
|
| - result.obj = decoder0.decodeServiceInterface(8, false, sample_import_mojom.ImportedInterfaceProxy.newFromEndpoint);
|
| + var decoder1 = decoder0.decodePointer(8, false);
|
| + result.packet = media_pipe_mojom.MediaPacket.decode(decoder1);
|
| }
|
| return result;
|
| }
|
| @@ -900,30 +708,30 @@ class _FactoryTakeImportedInterfaceParams extends bindings.Struct {
|
| void encode(bindings.Encoder encoder) {
|
| var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
|
|
| - encoder0.encodeInterface(obj, 8, false);
|
| + encoder0.encodeStruct(packet, 8, false);
|
| }
|
|
|
| String toString() {
|
| - return "_FactoryTakeImportedInterfaceParams("
|
| - "obj: $obj" ")";
|
| + return "_MediaConsumerPushPacketParams("
|
| + "packet: $packet" ")";
|
| }
|
|
|
| Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| + Map map = new Map();
|
| + map["packet"] = packet;
|
| + return map;
|
| }
|
| }
|
|
|
|
|
| -class FactoryTakeImportedInterfaceResponseParams extends bindings.Struct {
|
| +class MediaConsumerPushPacketResponseParams extends bindings.Struct {
|
| static const List<bindings.StructDataHeader> kVersions = const [
|
| - const bindings.StructDataHeader(16, 0)
|
| + const bindings.StructDataHeader(8, 0)
|
| ];
|
| - Object obj = null;
|
|
|
| - FactoryTakeImportedInterfaceResponseParams() : super(kVersions.last.size);
|
| + MediaConsumerPushPacketResponseParams() : super(kVersions.last.size);
|
|
|
| - static FactoryTakeImportedInterfaceResponseParams deserialize(bindings.Message message) {
|
| + static MediaConsumerPushPacketResponseParams deserialize(bindings.Message message) {
|
| var decoder = new bindings.Decoder(message);
|
| var result = decode(decoder);
|
| if (decoder.excessHandles != null) {
|
| @@ -932,11 +740,11 @@ class FactoryTakeImportedInterfaceResponseParams extends bindings.Struct {
|
| return result;
|
| }
|
|
|
| - static FactoryTakeImportedInterfaceResponseParams decode(bindings.Decoder decoder0) {
|
| + static MediaConsumerPushPacketResponseParams decode(bindings.Decoder decoder0) {
|
| if (decoder0 == null) {
|
| return null;
|
| }
|
| - FactoryTakeImportedInterfaceResponseParams result = new FactoryTakeImportedInterfaceResponseParams();
|
| + MediaConsumerPushPacketResponseParams result = new MediaConsumerPushPacketResponseParams();
|
|
|
| var mainDataHeader = decoder0.decodeStructDataHeader();
|
| if (mainDataHeader.version <= kVersions.last.version) {
|
| @@ -956,59 +764,52 @@ class FactoryTakeImportedInterfaceResponseParams extends bindings.Struct {
|
| 'Message newer than the last known version cannot be shorter than '
|
| 'required by the last known version.');
|
| }
|
| - if (mainDataHeader.version >= 0) {
|
| -
|
| - result.obj = decoder0.decodeServiceInterface(8, false, sample_import_mojom.ImportedInterfaceProxy.newFromEndpoint);
|
| - }
|
| return result;
|
| }
|
|
|
| void encode(bindings.Encoder encoder) {
|
| - var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
|
| -
|
| - encoder0.encodeInterface(obj, 8, false);
|
| + encoder.getStructEncoderAtOffset(kVersions.last);
|
| }
|
|
|
| String toString() {
|
| - return "FactoryTakeImportedInterfaceResponseParams("
|
| - "obj: $obj" ")";
|
| + return "MediaConsumerPushPacketResponseParams("")";
|
| }
|
|
|
| Map toJson() {
|
| - throw new bindings.MojoCodecError(
|
| - 'Object containing handles cannot be encoded to JSON.');
|
| + Map map = new Map();
|
| + return map;
|
| }
|
| }
|
|
|
| -const int _NamedObject_setNameName = 0;
|
| -const int _NamedObject_getNameName = 1;
|
| +const int _MediaProducer_connectName = 0;
|
| +const int _MediaProducer_disconnectName = 1;
|
|
|
| -abstract class NamedObject {
|
| - static const String serviceName = "sample::NamedObject";
|
| - void setName(String name);
|
| - dynamic getName([Function responseFactory = null]);
|
| +abstract class MediaProducer {
|
| + static const String serviceName = null;
|
| + dynamic connect(Object consumer,[Function responseFactory = null]);
|
| + void disconnect();
|
| }
|
|
|
|
|
| -class _NamedObjectProxyImpl extends bindings.Proxy {
|
| - _NamedObjectProxyImpl.fromEndpoint(
|
| +class _MediaProducerProxyImpl extends bindings.Proxy {
|
| + _MediaProducerProxyImpl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
|
|
| - _NamedObjectProxyImpl.fromHandle(core.MojoHandle handle) :
|
| + _MediaProducerProxyImpl.fromHandle(core.MojoHandle handle) :
|
| super.fromHandle(handle);
|
|
|
| - _NamedObjectProxyImpl.unbound() : super.unbound();
|
| + _MediaProducerProxyImpl.unbound() : super.unbound();
|
|
|
| - static _NamedObjectProxyImpl newFromEndpoint(
|
| + static _MediaProducerProxyImpl newFromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For _NamedObjectProxyImpl"));
|
| - return new _NamedObjectProxyImpl.fromEndpoint(endpoint);
|
| + assert(endpoint.setDescription("For _MediaProducerProxyImpl"));
|
| + return new _MediaProducerProxyImpl.fromEndpoint(endpoint);
|
| }
|
|
|
| void handleResponse(bindings.ServiceMessage message) {
|
| switch (message.header.type) {
|
| - case _NamedObject_getNameName:
|
| - var r = NamedObjectGetNameResponseParams.deserialize(
|
| + case _MediaProducer_connectName:
|
| + var r = MediaProducerConnectResponseParams.deserialize(
|
| message.payload);
|
| if (!message.header.hasRequestId) {
|
| proxyError("Expected a message with a valid request Id.");
|
| @@ -1036,73 +837,73 @@ class _NamedObjectProxyImpl extends bindings.Proxy {
|
|
|
| String toString() {
|
| var superString = super.toString();
|
| - return "_NamedObjectProxyImpl($superString)";
|
| + return "_MediaProducerProxyImpl($superString)";
|
| }
|
| }
|
|
|
|
|
| -class _NamedObjectProxyCalls implements NamedObject {
|
| - _NamedObjectProxyImpl _proxyImpl;
|
| +class _MediaProducerProxyCalls implements MediaProducer {
|
| + _MediaProducerProxyImpl _proxyImpl;
|
|
|
| - _NamedObjectProxyCalls(this._proxyImpl);
|
| - void setName(String name) {
|
| - if (!_proxyImpl.isBound) {
|
| - _proxyImpl.proxyError("The Proxy is closed.");
|
| - return;
|
| - }
|
| - var params = new _NamedObjectSetNameParams();
|
| - params.name = name;
|
| - _proxyImpl.sendMessage(params, _NamedObject_setNameName);
|
| - }
|
| - dynamic getName([Function responseFactory = null]) {
|
| - var params = new _NamedObjectGetNameParams();
|
| + _MediaProducerProxyCalls(this._proxyImpl);
|
| + dynamic connect(Object consumer,[Function responseFactory = null]) {
|
| + var params = new _MediaProducerConnectParams();
|
| + params.consumer = consumer;
|
| return _proxyImpl.sendMessageWithRequestId(
|
| params,
|
| - _NamedObject_getNameName,
|
| + _MediaProducer_connectName,
|
| -1,
|
| bindings.MessageHeader.kMessageExpectsResponse);
|
| }
|
| + void disconnect() {
|
| + if (!_proxyImpl.isBound) {
|
| + _proxyImpl.proxyError("The Proxy is closed.");
|
| + return;
|
| + }
|
| + var params = new _MediaProducerDisconnectParams();
|
| + _proxyImpl.sendMessage(params, _MediaProducer_disconnectName);
|
| + }
|
| }
|
|
|
|
|
| -class NamedObjectProxy implements bindings.ProxyBase {
|
| +class MediaProducerProxy implements bindings.ProxyBase {
|
| final bindings.Proxy impl;
|
| - NamedObject ptr;
|
| + MediaProducer ptr;
|
|
|
| - NamedObjectProxy(_NamedObjectProxyImpl proxyImpl) :
|
| + MediaProducerProxy(_MediaProducerProxyImpl proxyImpl) :
|
| impl = proxyImpl,
|
| - ptr = new _NamedObjectProxyCalls(proxyImpl);
|
| + ptr = new _MediaProducerProxyCalls(proxyImpl);
|
|
|
| - NamedObjectProxy.fromEndpoint(
|
| + MediaProducerProxy.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) :
|
| - impl = new _NamedObjectProxyImpl.fromEndpoint(endpoint) {
|
| - ptr = new _NamedObjectProxyCalls(impl);
|
| + impl = new _MediaProducerProxyImpl.fromEndpoint(endpoint) {
|
| + ptr = new _MediaProducerProxyCalls(impl);
|
| }
|
|
|
| - NamedObjectProxy.fromHandle(core.MojoHandle handle) :
|
| - impl = new _NamedObjectProxyImpl.fromHandle(handle) {
|
| - ptr = new _NamedObjectProxyCalls(impl);
|
| + MediaProducerProxy.fromHandle(core.MojoHandle handle) :
|
| + impl = new _MediaProducerProxyImpl.fromHandle(handle) {
|
| + ptr = new _MediaProducerProxyCalls(impl);
|
| }
|
|
|
| - NamedObjectProxy.unbound() :
|
| - impl = new _NamedObjectProxyImpl.unbound() {
|
| - ptr = new _NamedObjectProxyCalls(impl);
|
| + MediaProducerProxy.unbound() :
|
| + impl = new _MediaProducerProxyImpl.unbound() {
|
| + ptr = new _MediaProducerProxyCalls(impl);
|
| }
|
|
|
| - factory NamedObjectProxy.connectToService(
|
| + factory MediaProducerProxy.connectToService(
|
| bindings.ServiceConnector s, String url, [String serviceName]) {
|
| - NamedObjectProxy p = new NamedObjectProxy.unbound();
|
| + MediaProducerProxy p = new MediaProducerProxy.unbound();
|
| s.connectToService(url, p, serviceName);
|
| return p;
|
| }
|
|
|
| - static NamedObjectProxy newFromEndpoint(
|
| + static MediaProducerProxy newFromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For NamedObjectProxy"));
|
| - return new NamedObjectProxy.fromEndpoint(endpoint);
|
| + assert(endpoint.setDescription("For MediaProducerProxy"));
|
| + return new MediaProducerProxy.fromEndpoint(endpoint);
|
| }
|
|
|
| - String get serviceName => NamedObject.serviceName;
|
| + String get serviceName => MediaProducer.serviceName;
|
|
|
| Future close({bool immediate: false}) => impl.close(immediate: immediate);
|
|
|
| @@ -1119,33 +920,32 @@ class NamedObjectProxy implements bindings.ProxyBase {
|
| }
|
|
|
| String toString() {
|
| - return "NamedObjectProxy($impl)";
|
| + return "MediaProducerProxy($impl)";
|
| }
|
| }
|
|
|
|
|
| -class NamedObjectStub extends bindings.Stub {
|
| - NamedObject _impl = null;
|
| +class MediaProducerStub extends bindings.Stub {
|
| + MediaProducer _impl = null;
|
|
|
| - NamedObjectStub.fromEndpoint(
|
| + MediaProducerStub.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint, [this._impl])
|
| : super.fromEndpoint(endpoint);
|
|
|
| - NamedObjectStub.fromHandle(core.MojoHandle handle, [this._impl])
|
| + MediaProducerStub.fromHandle(core.MojoHandle handle, [this._impl])
|
| : super.fromHandle(handle);
|
|
|
| - NamedObjectStub.unbound() : super.unbound();
|
| + MediaProducerStub.unbound() : super.unbound();
|
|
|
| - static NamedObjectStub newFromEndpoint(
|
| + static MediaProducerStub newFromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For NamedObjectStub"));
|
| - return new NamedObjectStub.fromEndpoint(endpoint);
|
| + assert(endpoint.setDescription("For MediaProducerStub"));
|
| + return new MediaProducerStub.fromEndpoint(endpoint);
|
| }
|
|
|
|
|
| - NamedObjectGetNameResponseParams _NamedObjectGetNameResponseParamsFactory(String name) {
|
| - var mojo_factory_result = new NamedObjectGetNameResponseParams();
|
| - mojo_factory_result.name = name;
|
| + MediaProducerConnectResponseParams _MediaProducerConnectResponseParamsFactory() {
|
| + var mojo_factory_result = new MediaProducerConnectResponseParams();
|
| return mojo_factory_result;
|
| }
|
|
|
| @@ -1157,21 +957,16 @@ class NamedObjectStub extends bindings.Stub {
|
| }
|
| assert(_impl != null);
|
| switch (message.header.type) {
|
| - case _NamedObject_setNameName:
|
| - var params = _NamedObjectSetNameParams.deserialize(
|
| + case _MediaProducer_connectName:
|
| + var params = _MediaProducerConnectParams.deserialize(
|
| message.payload);
|
| - _impl.setName(params.name);
|
| - break;
|
| - case _NamedObject_getNameName:
|
| - var params = _NamedObjectGetNameParams.deserialize(
|
| - message.payload);
|
| - var response = _impl.getName(_NamedObjectGetNameResponseParamsFactory);
|
| + var response = _impl.connect(params.consumer,_MediaProducerConnectResponseParamsFactory);
|
| if (response is Future) {
|
| return response.then((response) {
|
| if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _NamedObject_getNameName,
|
| + _MediaProducer_connectName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| @@ -1179,11 +974,16 @@ class NamedObjectStub extends bindings.Stub {
|
| } else if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _NamedObject_getNameName,
|
| + _MediaProducer_connectName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| break;
|
| + case _MediaProducer_disconnectName:
|
| + var params = _MediaProducerDisconnectParams.deserialize(
|
| + message.payload);
|
| + _impl.disconnect();
|
| + break;
|
| default:
|
| throw new bindings.MojoCodecError("Unexpected message name");
|
| break;
|
| @@ -1191,55 +991,51 @@ class NamedObjectStub extends bindings.Stub {
|
| return null;
|
| }
|
|
|
| - NamedObject get impl => _impl;
|
| - set impl(NamedObject d) {
|
| + MediaProducer get impl => _impl;
|
| + set impl(MediaProducer d) {
|
| assert(_impl == null);
|
| _impl = d;
|
| }
|
|
|
| String toString() {
|
| var superString = super.toString();
|
| - return "NamedObjectStub($superString)";
|
| + return "MediaProducerStub($superString)";
|
| }
|
|
|
| int get version => 0;
|
| }
|
|
|
| -const int _Factory_doStuffName = 0;
|
| -const int _Factory_doStuff2Name = 1;
|
| -const int _Factory_createNamedObjectName = 2;
|
| -const int _Factory_requestImportedInterfaceName = 3;
|
| -const int _Factory_takeImportedInterfaceName = 4;
|
| +const int _MediaPullModeProducer_getBufferName = 0;
|
| +const int _MediaPullModeProducer_pullPacketName = 1;
|
| +const int _MediaPullModeProducer_releasePacketName = 2;
|
|
|
| -abstract class Factory {
|
| +abstract class MediaPullModeProducer {
|
| static const String serviceName = null;
|
| - dynamic doStuff(Request request,core.MojoMessagePipeEndpoint pipe,[Function responseFactory = null]);
|
| - dynamic doStuff2(core.MojoDataPipeConsumer pipe,[Function responseFactory = null]);
|
| - void createNamedObject(Object obj);
|
| - dynamic requestImportedInterface(Object obj,[Function responseFactory = null]);
|
| - dynamic takeImportedInterface(Object obj,[Function responseFactory = null]);
|
| + dynamic getBuffer([Function responseFactory = null]);
|
| + dynamic pullPacket(media_pipe_mojom.MediaPacket toRelease,[Function responseFactory = null]);
|
| + void releasePacket(media_pipe_mojom.MediaPacket toRelease);
|
| }
|
|
|
|
|
| -class _FactoryProxyImpl extends bindings.Proxy {
|
| - _FactoryProxyImpl.fromEndpoint(
|
| +class _MediaPullModeProducerProxyImpl extends bindings.Proxy {
|
| + _MediaPullModeProducerProxyImpl.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
|
|
| - _FactoryProxyImpl.fromHandle(core.MojoHandle handle) :
|
| + _MediaPullModeProducerProxyImpl.fromHandle(core.MojoHandle handle) :
|
| super.fromHandle(handle);
|
|
|
| - _FactoryProxyImpl.unbound() : super.unbound();
|
| + _MediaPullModeProducerProxyImpl.unbound() : super.unbound();
|
|
|
| - static _FactoryProxyImpl newFromEndpoint(
|
| + static _MediaPullModeProducerProxyImpl newFromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For _FactoryProxyImpl"));
|
| - return new _FactoryProxyImpl.fromEndpoint(endpoint);
|
| + assert(endpoint.setDescription("For _MediaPullModeProducerProxyImpl"));
|
| + return new _MediaPullModeProducerProxyImpl.fromEndpoint(endpoint);
|
| }
|
|
|
| void handleResponse(bindings.ServiceMessage message) {
|
| switch (message.header.type) {
|
| - case _Factory_doStuffName:
|
| - var r = FactoryDoStuffResponseParams.deserialize(
|
| + case _MediaPullModeProducer_getBufferName:
|
| + var r = MediaPullModeProducerGetBufferResponseParams.deserialize(
|
| message.payload);
|
| if (!message.header.hasRequestId) {
|
| proxyError("Expected a message with a valid request Id.");
|
| @@ -1258,48 +1054,8 @@ class _FactoryProxyImpl extends bindings.Proxy {
|
| }
|
| c.complete(r);
|
| break;
|
| - case _Factory_doStuff2Name:
|
| - var r = FactoryDoStuff2ResponseParams.deserialize(
|
| - message.payload);
|
| - if (!message.header.hasRequestId) {
|
| - proxyError("Expected a message with a valid request Id.");
|
| - return;
|
| - }
|
| - Completer c = completerMap[message.header.requestId];
|
| - if (c == null) {
|
| - proxyError(
|
| - "Message had unknown request Id: ${message.header.requestId}");
|
| - return;
|
| - }
|
| - completerMap.remove(message.header.requestId);
|
| - if (c.isCompleted) {
|
| - proxyError("Response completer already completed");
|
| - return;
|
| - }
|
| - c.complete(r);
|
| - break;
|
| - case _Factory_requestImportedInterfaceName:
|
| - var r = FactoryRequestImportedInterfaceResponseParams.deserialize(
|
| - message.payload);
|
| - if (!message.header.hasRequestId) {
|
| - proxyError("Expected a message with a valid request Id.");
|
| - return;
|
| - }
|
| - Completer c = completerMap[message.header.requestId];
|
| - if (c == null) {
|
| - proxyError(
|
| - "Message had unknown request Id: ${message.header.requestId}");
|
| - return;
|
| - }
|
| - completerMap.remove(message.header.requestId);
|
| - if (c.isCompleted) {
|
| - proxyError("Response completer already completed");
|
| - return;
|
| - }
|
| - c.complete(r);
|
| - break;
|
| - case _Factory_takeImportedInterfaceName:
|
| - var r = FactoryTakeImportedInterfaceResponseParams.deserialize(
|
| + case _MediaPullModeProducer_pullPacketName:
|
| + var r = MediaPullModeProducerPullPacketResponseParams.deserialize(
|
| message.payload);
|
| if (!message.header.hasRequestId) {
|
| proxyError("Expected a message with a valid request Id.");
|
| @@ -1327,102 +1083,82 @@ class _FactoryProxyImpl extends bindings.Proxy {
|
|
|
| String toString() {
|
| var superString = super.toString();
|
| - return "_FactoryProxyImpl($superString)";
|
| + return "_MediaPullModeProducerProxyImpl($superString)";
|
| }
|
| }
|
|
|
|
|
| -class _FactoryProxyCalls implements Factory {
|
| - _FactoryProxyImpl _proxyImpl;
|
| +class _MediaPullModeProducerProxyCalls implements MediaPullModeProducer {
|
| + _MediaPullModeProducerProxyImpl _proxyImpl;
|
|
|
| - _FactoryProxyCalls(this._proxyImpl);
|
| - dynamic doStuff(Request request,core.MojoMessagePipeEndpoint pipe,[Function responseFactory = null]) {
|
| - var params = new _FactoryDoStuffParams();
|
| - params.request = request;
|
| - params.pipe = pipe;
|
| + _MediaPullModeProducerProxyCalls(this._proxyImpl);
|
| + dynamic getBuffer([Function responseFactory = null]) {
|
| + var params = new _MediaPullModeProducerGetBufferParams();
|
| return _proxyImpl.sendMessageWithRequestId(
|
| params,
|
| - _Factory_doStuffName,
|
| + _MediaPullModeProducer_getBufferName,
|
| -1,
|
| bindings.MessageHeader.kMessageExpectsResponse);
|
| }
|
| - dynamic doStuff2(core.MojoDataPipeConsumer pipe,[Function responseFactory = null]) {
|
| - var params = new _FactoryDoStuff2Params();
|
| - params.pipe = pipe;
|
| + dynamic pullPacket(media_pipe_mojom.MediaPacket toRelease,[Function responseFactory = null]) {
|
| + var params = new _MediaPullModeProducerPullPacketParams();
|
| + params.toRelease = toRelease;
|
| return _proxyImpl.sendMessageWithRequestId(
|
| params,
|
| - _Factory_doStuff2Name,
|
| + _MediaPullModeProducer_pullPacketName,
|
| -1,
|
| bindings.MessageHeader.kMessageExpectsResponse);
|
| }
|
| - void createNamedObject(Object obj) {
|
| + void releasePacket(media_pipe_mojom.MediaPacket toRelease) {
|
| if (!_proxyImpl.isBound) {
|
| _proxyImpl.proxyError("The Proxy is closed.");
|
| return;
|
| }
|
| - var params = new _FactoryCreateNamedObjectParams();
|
| - params.obj = obj;
|
| - _proxyImpl.sendMessage(params, _Factory_createNamedObjectName);
|
| - }
|
| - dynamic requestImportedInterface(Object obj,[Function responseFactory = null]) {
|
| - var params = new _FactoryRequestImportedInterfaceParams();
|
| - params.obj = obj;
|
| - return _proxyImpl.sendMessageWithRequestId(
|
| - params,
|
| - _Factory_requestImportedInterfaceName,
|
| - -1,
|
| - bindings.MessageHeader.kMessageExpectsResponse);
|
| - }
|
| - dynamic takeImportedInterface(Object obj,[Function responseFactory = null]) {
|
| - var params = new _FactoryTakeImportedInterfaceParams();
|
| - params.obj = obj;
|
| - return _proxyImpl.sendMessageWithRequestId(
|
| - params,
|
| - _Factory_takeImportedInterfaceName,
|
| - -1,
|
| - bindings.MessageHeader.kMessageExpectsResponse);
|
| + var params = new _MediaPullModeProducerReleasePacketParams();
|
| + params.toRelease = toRelease;
|
| + _proxyImpl.sendMessage(params, _MediaPullModeProducer_releasePacketName);
|
| }
|
| }
|
|
|
|
|
| -class FactoryProxy implements bindings.ProxyBase {
|
| +class MediaPullModeProducerProxy implements bindings.ProxyBase {
|
| final bindings.Proxy impl;
|
| - Factory ptr;
|
| + MediaPullModeProducer ptr;
|
|
|
| - FactoryProxy(_FactoryProxyImpl proxyImpl) :
|
| + MediaPullModeProducerProxy(_MediaPullModeProducerProxyImpl proxyImpl) :
|
| impl = proxyImpl,
|
| - ptr = new _FactoryProxyCalls(proxyImpl);
|
| + ptr = new _MediaPullModeProducerProxyCalls(proxyImpl);
|
|
|
| - FactoryProxy.fromEndpoint(
|
| + MediaPullModeProducerProxy.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) :
|
| - impl = new _FactoryProxyImpl.fromEndpoint(endpoint) {
|
| - ptr = new _FactoryProxyCalls(impl);
|
| + impl = new _MediaPullModeProducerProxyImpl.fromEndpoint(endpoint) {
|
| + ptr = new _MediaPullModeProducerProxyCalls(impl);
|
| }
|
|
|
| - FactoryProxy.fromHandle(core.MojoHandle handle) :
|
| - impl = new _FactoryProxyImpl.fromHandle(handle) {
|
| - ptr = new _FactoryProxyCalls(impl);
|
| + MediaPullModeProducerProxy.fromHandle(core.MojoHandle handle) :
|
| + impl = new _MediaPullModeProducerProxyImpl.fromHandle(handle) {
|
| + ptr = new _MediaPullModeProducerProxyCalls(impl);
|
| }
|
|
|
| - FactoryProxy.unbound() :
|
| - impl = new _FactoryProxyImpl.unbound() {
|
| - ptr = new _FactoryProxyCalls(impl);
|
| + MediaPullModeProducerProxy.unbound() :
|
| + impl = new _MediaPullModeProducerProxyImpl.unbound() {
|
| + ptr = new _MediaPullModeProducerProxyCalls(impl);
|
| }
|
|
|
| - factory FactoryProxy.connectToService(
|
| + factory MediaPullModeProducerProxy.connectToService(
|
| bindings.ServiceConnector s, String url, [String serviceName]) {
|
| - FactoryProxy p = new FactoryProxy.unbound();
|
| + MediaPullModeProducerProxy p = new MediaPullModeProducerProxy.unbound();
|
| s.connectToService(url, p, serviceName);
|
| return p;
|
| }
|
|
|
| - static FactoryProxy newFromEndpoint(
|
| + static MediaPullModeProducerProxy newFromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For FactoryProxy"));
|
| - return new FactoryProxy.fromEndpoint(endpoint);
|
| + assert(endpoint.setDescription("For MediaPullModeProducerProxy"));
|
| + return new MediaPullModeProducerProxy.fromEndpoint(endpoint);
|
| }
|
|
|
| - String get serviceName => Factory.serviceName;
|
| + String get serviceName => MediaPullModeProducer.serviceName;
|
|
|
| Future close({bool immediate: false}) => impl.close(immediate: immediate);
|
|
|
| @@ -1439,49 +1175,38 @@ class FactoryProxy implements bindings.ProxyBase {
|
| }
|
|
|
| String toString() {
|
| - return "FactoryProxy($impl)";
|
| + return "MediaPullModeProducerProxy($impl)";
|
| }
|
| }
|
|
|
|
|
| -class FactoryStub extends bindings.Stub {
|
| - Factory _impl = null;
|
| +class MediaPullModeProducerStub extends bindings.Stub {
|
| + MediaPullModeProducer _impl = null;
|
|
|
| - FactoryStub.fromEndpoint(
|
| + MediaPullModeProducerStub.fromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint, [this._impl])
|
| : super.fromEndpoint(endpoint);
|
|
|
| - FactoryStub.fromHandle(core.MojoHandle handle, [this._impl])
|
| + MediaPullModeProducerStub.fromHandle(core.MojoHandle handle, [this._impl])
|
| : super.fromHandle(handle);
|
|
|
| - FactoryStub.unbound() : super.unbound();
|
| + MediaPullModeProducerStub.unbound() : super.unbound();
|
|
|
| - static FactoryStub newFromEndpoint(
|
| + static MediaPullModeProducerStub newFromEndpoint(
|
| core.MojoMessagePipeEndpoint endpoint) {
|
| - assert(endpoint.setDescription("For FactoryStub"));
|
| - return new FactoryStub.fromEndpoint(endpoint);
|
| + assert(endpoint.setDescription("For MediaPullModeProducerStub"));
|
| + return new MediaPullModeProducerStub.fromEndpoint(endpoint);
|
| }
|
|
|
|
|
| - FactoryDoStuffResponseParams _FactoryDoStuffResponseParamsFactory(Response response, String text) {
|
| - var mojo_factory_result = new FactoryDoStuffResponseParams();
|
| - mojo_factory_result.response = response;
|
| - mojo_factory_result.text = text;
|
| + MediaPullModeProducerGetBufferResponseParams _MediaPullModeProducerGetBufferResponseParamsFactory(core.MojoSharedBuffer buffer) {
|
| + var mojo_factory_result = new MediaPullModeProducerGetBufferResponseParams();
|
| + mojo_factory_result.buffer = buffer;
|
| return mojo_factory_result;
|
| }
|
| - FactoryDoStuff2ResponseParams _FactoryDoStuff2ResponseParamsFactory(String text) {
|
| - var mojo_factory_result = new FactoryDoStuff2ResponseParams();
|
| - mojo_factory_result.text = text;
|
| - return mojo_factory_result;
|
| - }
|
| - FactoryRequestImportedInterfaceResponseParams _FactoryRequestImportedInterfaceResponseParamsFactory(Object obj) {
|
| - var mojo_factory_result = new FactoryRequestImportedInterfaceResponseParams();
|
| - mojo_factory_result.obj = obj;
|
| - return mojo_factory_result;
|
| - }
|
| - FactoryTakeImportedInterfaceResponseParams _FactoryTakeImportedInterfaceResponseParamsFactory(Object obj) {
|
| - var mojo_factory_result = new FactoryTakeImportedInterfaceResponseParams();
|
| - mojo_factory_result.obj = obj;
|
| + MediaPullModeProducerPullPacketResponseParams _MediaPullModeProducerPullPacketResponseParamsFactory(media_pipe_mojom.MediaPacket packet) {
|
| + var mojo_factory_result = new MediaPullModeProducerPullPacketResponseParams();
|
| + mojo_factory_result.packet = packet;
|
| return mojo_factory_result;
|
| }
|
|
|
| @@ -1493,16 +1218,16 @@ class FactoryStub extends bindings.Stub {
|
| }
|
| assert(_impl != null);
|
| switch (message.header.type) {
|
| - case _Factory_doStuffName:
|
| - var params = _FactoryDoStuffParams.deserialize(
|
| + case _MediaPullModeProducer_getBufferName:
|
| + var params = _MediaPullModeProducerGetBufferParams.deserialize(
|
| message.payload);
|
| - var response = _impl.doStuff(params.request,params.pipe,_FactoryDoStuffResponseParamsFactory);
|
| + var response = _impl.getBuffer(_MediaPullModeProducerGetBufferResponseParamsFactory);
|
| if (response is Future) {
|
| return response.then((response) {
|
| if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_doStuffName,
|
| + _MediaPullModeProducer_getBufferName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| @@ -1510,21 +1235,21 @@ class FactoryStub extends bindings.Stub {
|
| } else if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_doStuffName,
|
| + _MediaPullModeProducer_getBufferName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| break;
|
| - case _Factory_doStuff2Name:
|
| - var params = _FactoryDoStuff2Params.deserialize(
|
| + case _MediaPullModeProducer_pullPacketName:
|
| + var params = _MediaPullModeProducerPullPacketParams.deserialize(
|
| message.payload);
|
| - var response = _impl.doStuff2(params.pipe,_FactoryDoStuff2ResponseParamsFactory);
|
| + var response = _impl.pullPacket(params.toRelease,_MediaPullModeProducerPullPacketResponseParamsFactory);
|
| if (response is Future) {
|
| return response.then((response) {
|
| if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_doStuff2Name,
|
| + _MediaPullModeProducer_pullPacketName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| @@ -1532,26 +1257,249 @@ class FactoryStub extends bindings.Stub {
|
| } else if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_doStuff2Name,
|
| + _MediaPullModeProducer_pullPacketName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| break;
|
| - case _Factory_createNamedObjectName:
|
| - var params = _FactoryCreateNamedObjectParams.deserialize(
|
| + case _MediaPullModeProducer_releasePacketName:
|
| + var params = _MediaPullModeProducerReleasePacketParams.deserialize(
|
| message.payload);
|
| - _impl.createNamedObject(params.obj);
|
| + _impl.releasePacket(params.toRelease);
|
| + break;
|
| + default:
|
| + throw new bindings.MojoCodecError("Unexpected message name");
|
| + break;
|
| + }
|
| + return null;
|
| + }
|
| +
|
| + MediaPullModeProducer get impl => _impl;
|
| + set impl(MediaPullModeProducer d) {
|
| + assert(_impl == null);
|
| + _impl = d;
|
| + }
|
| +
|
| + String toString() {
|
| + var superString = super.toString();
|
| + return "MediaPullModeProducerStub($superString)";
|
| + }
|
| +
|
| + int get version => 0;
|
| +}
|
| +
|
| +const int _MediaConsumer_setBufferName = 0;
|
| +const int _MediaConsumer_pushPacketName = 1;
|
| +
|
| +abstract class MediaConsumer {
|
| + static const String serviceName = null;
|
| + dynamic setBuffer(core.MojoSharedBuffer buffer,int size,[Function responseFactory = null]);
|
| + dynamic pushPacket(media_pipe_mojom.MediaPacket packet,[Function responseFactory = null]);
|
| +}
|
| +
|
| +
|
| +class _MediaConsumerProxyImpl extends bindings.Proxy {
|
| + _MediaConsumerProxyImpl.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
|
| +
|
| + _MediaConsumerProxyImpl.fromHandle(core.MojoHandle handle) :
|
| + super.fromHandle(handle);
|
| +
|
| + _MediaConsumerProxyImpl.unbound() : super.unbound();
|
| +
|
| + static _MediaConsumerProxyImpl newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For _MediaConsumerProxyImpl"));
|
| + return new _MediaConsumerProxyImpl.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + void handleResponse(bindings.ServiceMessage message) {
|
| + switch (message.header.type) {
|
| + case _MediaConsumer_setBufferName:
|
| + var r = MediaConsumerSetBufferResponseParams.deserialize(
|
| + message.payload);
|
| + if (!message.header.hasRequestId) {
|
| + proxyError("Expected a message with a valid request Id.");
|
| + return;
|
| + }
|
| + Completer c = completerMap[message.header.requestId];
|
| + if (c == null) {
|
| + proxyError(
|
| + "Message had unknown request Id: ${message.header.requestId}");
|
| + return;
|
| + }
|
| + completerMap.remove(message.header.requestId);
|
| + if (c.isCompleted) {
|
| + proxyError("Response completer already completed");
|
| + return;
|
| + }
|
| + c.complete(r);
|
| + break;
|
| + case _MediaConsumer_pushPacketName:
|
| + var r = MediaConsumerPushPacketResponseParams.deserialize(
|
| + message.payload);
|
| + if (!message.header.hasRequestId) {
|
| + proxyError("Expected a message with a valid request Id.");
|
| + return;
|
| + }
|
| + Completer c = completerMap[message.header.requestId];
|
| + if (c == null) {
|
| + proxyError(
|
| + "Message had unknown request Id: ${message.header.requestId}");
|
| + return;
|
| + }
|
| + completerMap.remove(message.header.requestId);
|
| + if (c.isCompleted) {
|
| + proxyError("Response completer already completed");
|
| + return;
|
| + }
|
| + c.complete(r);
|
| break;
|
| - case _Factory_requestImportedInterfaceName:
|
| - var params = _FactoryRequestImportedInterfaceParams.deserialize(
|
| + default:
|
| + proxyError("Unexpected message type: ${message.header.type}");
|
| + close(immediate: true);
|
| + break;
|
| + }
|
| + }
|
| +
|
| + String toString() {
|
| + var superString = super.toString();
|
| + return "_MediaConsumerProxyImpl($superString)";
|
| + }
|
| +}
|
| +
|
| +
|
| +class _MediaConsumerProxyCalls implements MediaConsumer {
|
| + _MediaConsumerProxyImpl _proxyImpl;
|
| +
|
| + _MediaConsumerProxyCalls(this._proxyImpl);
|
| + dynamic setBuffer(core.MojoSharedBuffer buffer,int size,[Function responseFactory = null]) {
|
| + var params = new _MediaConsumerSetBufferParams();
|
| + params.buffer = buffer;
|
| + params.size = size;
|
| + return _proxyImpl.sendMessageWithRequestId(
|
| + params,
|
| + _MediaConsumer_setBufferName,
|
| + -1,
|
| + bindings.MessageHeader.kMessageExpectsResponse);
|
| + }
|
| + dynamic pushPacket(media_pipe_mojom.MediaPacket packet,[Function responseFactory = null]) {
|
| + var params = new _MediaConsumerPushPacketParams();
|
| + params.packet = packet;
|
| + return _proxyImpl.sendMessageWithRequestId(
|
| + params,
|
| + _MediaConsumer_pushPacketName,
|
| + -1,
|
| + bindings.MessageHeader.kMessageExpectsResponse);
|
| + }
|
| +}
|
| +
|
| +
|
| +class MediaConsumerProxy implements bindings.ProxyBase {
|
| + final bindings.Proxy impl;
|
| + MediaConsumer ptr;
|
| +
|
| + MediaConsumerProxy(_MediaConsumerProxyImpl proxyImpl) :
|
| + impl = proxyImpl,
|
| + ptr = new _MediaConsumerProxyCalls(proxyImpl);
|
| +
|
| + MediaConsumerProxy.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) :
|
| + impl = new _MediaConsumerProxyImpl.fromEndpoint(endpoint) {
|
| + ptr = new _MediaConsumerProxyCalls(impl);
|
| + }
|
| +
|
| + MediaConsumerProxy.fromHandle(core.MojoHandle handle) :
|
| + impl = new _MediaConsumerProxyImpl.fromHandle(handle) {
|
| + ptr = new _MediaConsumerProxyCalls(impl);
|
| + }
|
| +
|
| + MediaConsumerProxy.unbound() :
|
| + impl = new _MediaConsumerProxyImpl.unbound() {
|
| + ptr = new _MediaConsumerProxyCalls(impl);
|
| + }
|
| +
|
| + factory MediaConsumerProxy.connectToService(
|
| + bindings.ServiceConnector s, String url, [String serviceName]) {
|
| + MediaConsumerProxy p = new MediaConsumerProxy.unbound();
|
| + s.connectToService(url, p, serviceName);
|
| + return p;
|
| + }
|
| +
|
| + static MediaConsumerProxy newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For MediaConsumerProxy"));
|
| + return new MediaConsumerProxy.fromEndpoint(endpoint);
|
| + }
|
| +
|
| + String get serviceName => MediaConsumer.serviceName;
|
| +
|
| + Future close({bool immediate: false}) => impl.close(immediate: immediate);
|
| +
|
| + Future responseOrError(Future f) => impl.responseOrError(f);
|
| +
|
| + Future get errorFuture => impl.errorFuture;
|
| +
|
| + int get version => impl.version;
|
| +
|
| + Future<int> queryVersion() => impl.queryVersion();
|
| +
|
| + void requireVersion(int requiredVersion) {
|
| + impl.requireVersion(requiredVersion);
|
| + }
|
| +
|
| + String toString() {
|
| + return "MediaConsumerProxy($impl)";
|
| + }
|
| +}
|
| +
|
| +
|
| +class MediaConsumerStub extends bindings.Stub {
|
| + MediaConsumer _impl = null;
|
| +
|
| + MediaConsumerStub.fromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint, [this._impl])
|
| + : super.fromEndpoint(endpoint);
|
| +
|
| + MediaConsumerStub.fromHandle(core.MojoHandle handle, [this._impl])
|
| + : super.fromHandle(handle);
|
| +
|
| + MediaConsumerStub.unbound() : super.unbound();
|
| +
|
| + static MediaConsumerStub newFromEndpoint(
|
| + core.MojoMessagePipeEndpoint endpoint) {
|
| + assert(endpoint.setDescription("For MediaConsumerStub"));
|
| + return new MediaConsumerStub.fromEndpoint(endpoint);
|
| + }
|
| +
|
| +
|
| + MediaConsumerSetBufferResponseParams _MediaConsumerSetBufferResponseParamsFactory() {
|
| + var mojo_factory_result = new MediaConsumerSetBufferResponseParams();
|
| + return mojo_factory_result;
|
| + }
|
| + MediaConsumerPushPacketResponseParams _MediaConsumerPushPacketResponseParamsFactory() {
|
| + var mojo_factory_result = new MediaConsumerPushPacketResponseParams();
|
| + return mojo_factory_result;
|
| + }
|
| +
|
| + dynamic handleMessage(bindings.ServiceMessage message) {
|
| + if (bindings.ControlMessageHandler.isControlMessage(message)) {
|
| + return bindings.ControlMessageHandler.handleMessage(this,
|
| + 0,
|
| + message);
|
| + }
|
| + assert(_impl != null);
|
| + switch (message.header.type) {
|
| + case _MediaConsumer_setBufferName:
|
| + var params = _MediaConsumerSetBufferParams.deserialize(
|
| message.payload);
|
| - var response = _impl.requestImportedInterface(params.obj,_FactoryRequestImportedInterfaceResponseParamsFactory);
|
| + var response = _impl.setBuffer(params.buffer,params.size,_MediaConsumerSetBufferResponseParamsFactory);
|
| if (response is Future) {
|
| return response.then((response) {
|
| if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_requestImportedInterfaceName,
|
| + _MediaConsumer_setBufferName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| @@ -1559,21 +1507,21 @@ class FactoryStub extends bindings.Stub {
|
| } else if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_requestImportedInterfaceName,
|
| + _MediaConsumer_setBufferName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| break;
|
| - case _Factory_takeImportedInterfaceName:
|
| - var params = _FactoryTakeImportedInterfaceParams.deserialize(
|
| + case _MediaConsumer_pushPacketName:
|
| + var params = _MediaConsumerPushPacketParams.deserialize(
|
| message.payload);
|
| - var response = _impl.takeImportedInterface(params.obj,_FactoryTakeImportedInterfaceResponseParamsFactory);
|
| + var response = _impl.pushPacket(params.packet,_MediaConsumerPushPacketResponseParamsFactory);
|
| if (response is Future) {
|
| return response.then((response) {
|
| if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_takeImportedInterfaceName,
|
| + _MediaConsumer_pushPacketName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| @@ -1581,7 +1529,7 @@ class FactoryStub extends bindings.Stub {
|
| } else if (response != null) {
|
| return buildResponseWithId(
|
| response,
|
| - _Factory_takeImportedInterfaceName,
|
| + _MediaConsumer_pushPacketName,
|
| message.header.requestId,
|
| bindings.MessageHeader.kMessageIsResponse);
|
| }
|
| @@ -1593,15 +1541,15 @@ class FactoryStub extends bindings.Stub {
|
| return null;
|
| }
|
|
|
| - Factory get impl => _impl;
|
| - set impl(Factory d) {
|
| + MediaConsumer get impl => _impl;
|
| + set impl(MediaConsumer d) {
|
| assert(_impl == null);
|
| _impl = d;
|
| }
|
|
|
| String toString() {
|
| var superString = super.toString();
|
| - return "FactoryStub($superString)";
|
| + return "MediaConsumerStub($superString)";
|
| }
|
|
|
| int get version => 0;
|
|
|