OLD | NEW |
1 // WARNING: DO NOT EDIT. This file was generated by a program. | 1 // WARNING: DO NOT EDIT. This file was generated by a program. |
2 // See $MOJO_SDK/tools/bindings/mojom_bindings_generator.py. | 2 // See $MOJO_SDK/tools/bindings/mojom_bindings_generator.py. |
3 | 3 |
4 library seeking_reader_mojom; | 4 library seeking_reader_mojom; |
5 import 'dart:async'; | 5 import 'dart:async'; |
6 import 'package:mojo/bindings.dart' as bindings; | 6 import 'package:mojo/bindings.dart' as bindings; |
7 import 'package:mojo/core.dart' as core; | 7 import 'package:mojo/core.dart' as core; |
8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
9 import 'package:mojo_services/mojo/media/media_common.mojom.dart' as media_commo
n_mojom; | 9 import 'package:mojo_services/mojo/media/media_common.mojom.dart' as media_commo
n_mojom; |
10 | 10 |
11 | 11 |
12 | 12 |
13 class _SeekingReaderDescribeParams extends bindings.Struct { | 13 class _SeekingReaderDescribeParams extends bindings.Struct { |
14 static const List<bindings.StructDataHeader> kVersions = const [ | 14 static const List<bindings.StructDataHeader> kVersions = const [ |
15 const bindings.StructDataHeader(8, 0) | 15 const bindings.StructDataHeader(8, 0) |
16 ]; | 16 ]; |
17 | 17 |
18 _SeekingReaderDescribeParams() : super(kVersions.last.size); | 18 _SeekingReaderDescribeParams() : super(kVersions.last.size); |
19 | 19 |
| 20 _SeekingReaderDescribeParams.init( |
| 21 ) : super(kVersions.last.size); |
| 22 |
20 static _SeekingReaderDescribeParams deserialize(bindings.Message message) { | 23 static _SeekingReaderDescribeParams deserialize(bindings.Message message) { |
21 var decoder = new bindings.Decoder(message); | 24 var decoder = new bindings.Decoder(message); |
22 var result = decode(decoder); | 25 var result = decode(decoder); |
23 if (decoder.excessHandles != null) { | 26 if (decoder.excessHandles != null) { |
24 decoder.excessHandles.forEach((h) => h.close()); | 27 decoder.excessHandles.forEach((h) => h.close()); |
25 } | 28 } |
26 return result; | 29 return result; |
27 } | 30 } |
28 | 31 |
29 static _SeekingReaderDescribeParams decode(bindings.Decoder decoder0) { | 32 static _SeekingReaderDescribeParams decode(bindings.Decoder decoder0) { |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
71 class SeekingReaderDescribeResponseParams extends bindings.Struct { | 74 class SeekingReaderDescribeResponseParams extends bindings.Struct { |
72 static const List<bindings.StructDataHeader> kVersions = const [ | 75 static const List<bindings.StructDataHeader> kVersions = const [ |
73 const bindings.StructDataHeader(24, 0) | 76 const bindings.StructDataHeader(24, 0) |
74 ]; | 77 ]; |
75 media_common_mojom.MediaResult result = null; | 78 media_common_mojom.MediaResult result = null; |
76 bool canSeek = false; | 79 bool canSeek = false; |
77 int size = 0; | 80 int size = 0; |
78 | 81 |
79 SeekingReaderDescribeResponseParams() : super(kVersions.last.size); | 82 SeekingReaderDescribeResponseParams() : super(kVersions.last.size); |
80 | 83 |
| 84 SeekingReaderDescribeResponseParams.init( |
| 85 media_common_mojom.MediaResult this.result, |
| 86 bool this.canSeek, |
| 87 int this.size |
| 88 ) : super(kVersions.last.size); |
| 89 |
81 static SeekingReaderDescribeResponseParams deserialize(bindings.Message messag
e) { | 90 static SeekingReaderDescribeResponseParams deserialize(bindings.Message messag
e) { |
82 var decoder = new bindings.Decoder(message); | 91 var decoder = new bindings.Decoder(message); |
83 var result = decode(decoder); | 92 var result = decode(decoder); |
84 if (decoder.excessHandles != null) { | 93 if (decoder.excessHandles != null) { |
85 decoder.excessHandles.forEach((h) => h.close()); | 94 decoder.excessHandles.forEach((h) => h.close()); |
86 } | 95 } |
87 return result; | 96 return result; |
88 } | 97 } |
89 | 98 |
90 static SeekingReaderDescribeResponseParams decode(bindings.Decoder decoder0) { | 99 static SeekingReaderDescribeResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
173 | 182 |
174 | 183 |
175 class _SeekingReaderReadAtParams extends bindings.Struct { | 184 class _SeekingReaderReadAtParams extends bindings.Struct { |
176 static const List<bindings.StructDataHeader> kVersions = const [ | 185 static const List<bindings.StructDataHeader> kVersions = const [ |
177 const bindings.StructDataHeader(16, 0) | 186 const bindings.StructDataHeader(16, 0) |
178 ]; | 187 ]; |
179 int position = 0; | 188 int position = 0; |
180 | 189 |
181 _SeekingReaderReadAtParams() : super(kVersions.last.size); | 190 _SeekingReaderReadAtParams() : super(kVersions.last.size); |
182 | 191 |
| 192 _SeekingReaderReadAtParams.init( |
| 193 int this.position |
| 194 ) : super(kVersions.last.size); |
| 195 |
183 static _SeekingReaderReadAtParams deserialize(bindings.Message message) { | 196 static _SeekingReaderReadAtParams deserialize(bindings.Message message) { |
184 var decoder = new bindings.Decoder(message); | 197 var decoder = new bindings.Decoder(message); |
185 var result = decode(decoder); | 198 var result = decode(decoder); |
186 if (decoder.excessHandles != null) { | 199 if (decoder.excessHandles != null) { |
187 decoder.excessHandles.forEach((h) => h.close()); | 200 decoder.excessHandles.forEach((h) => h.close()); |
188 } | 201 } |
189 return result; | 202 return result; |
190 } | 203 } |
191 | 204 |
192 static _SeekingReaderReadAtParams decode(bindings.Decoder decoder0) { | 205 static _SeekingReaderReadAtParams decode(bindings.Decoder decoder0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
246 | 259 |
247 class SeekingReaderReadAtResponseParams extends bindings.Struct { | 260 class SeekingReaderReadAtResponseParams extends bindings.Struct { |
248 static const List<bindings.StructDataHeader> kVersions = const [ | 261 static const List<bindings.StructDataHeader> kVersions = const [ |
249 const bindings.StructDataHeader(16, 0) | 262 const bindings.StructDataHeader(16, 0) |
250 ]; | 263 ]; |
251 media_common_mojom.MediaResult result = null; | 264 media_common_mojom.MediaResult result = null; |
252 core.MojoDataPipeConsumer dataPipe = null; | 265 core.MojoDataPipeConsumer dataPipe = null; |
253 | 266 |
254 SeekingReaderReadAtResponseParams() : super(kVersions.last.size); | 267 SeekingReaderReadAtResponseParams() : super(kVersions.last.size); |
255 | 268 |
| 269 SeekingReaderReadAtResponseParams.init( |
| 270 media_common_mojom.MediaResult this.result, |
| 271 core.MojoDataPipeConsumer this.dataPipe |
| 272 ) : super(kVersions.last.size); |
| 273 |
256 static SeekingReaderReadAtResponseParams deserialize(bindings.Message message)
{ | 274 static SeekingReaderReadAtResponseParams deserialize(bindings.Message message)
{ |
257 var decoder = new bindings.Decoder(message); | 275 var decoder = new bindings.Decoder(message); |
258 var result = decode(decoder); | 276 var result = decode(decoder); |
259 if (decoder.excessHandles != null) { | 277 if (decoder.excessHandles != null) { |
260 decoder.excessHandles.forEach((h) => h.close()); | 278 decoder.excessHandles.forEach((h) => h.close()); |
261 } | 279 } |
262 return result; | 280 return result; |
263 } | 281 } |
264 | 282 |
265 static SeekingReaderReadAtResponseParams decode(bindings.Decoder decoder0) { | 283 static SeekingReaderReadAtResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
328 Map toJson() { | 346 Map toJson() { |
329 throw new bindings.MojoCodecError( | 347 throw new bindings.MojoCodecError( |
330 'Object containing handles cannot be encoded to JSON.'); | 348 'Object containing handles cannot be encoded to JSON.'); |
331 } | 349 } |
332 } | 350 } |
333 | 351 |
334 const int _seekingReaderMethodDescribeName = 0; | 352 const int _seekingReaderMethodDescribeName = 0; |
335 const int _seekingReaderMethodReadAtName = 1; | 353 const int _seekingReaderMethodReadAtName = 1; |
336 | 354 |
337 class _SeekingReaderServiceDescription implements service_describer.ServiceDescr
iption { | 355 class _SeekingReaderServiceDescription implements service_describer.ServiceDescr
iption { |
338 dynamic getTopLevelInterface([Function responseFactory]) => | 356 void getTopLevelInterface(Function responder) { |
339 responseFactory(null); | 357 responder(null); |
| 358 } |
340 | 359 |
341 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 360 void getTypeDefinition(String typeKey, Function responder) { |
342 responseFactory(null); | 361 responder(null); |
| 362 } |
343 | 363 |
344 dynamic getAllTypeDefinitions([Function responseFactory]) => | 364 void getAllTypeDefinitions(Function responder) { |
345 responseFactory(null); | 365 responder(null); |
| 366 } |
346 } | 367 } |
347 | 368 |
348 abstract class SeekingReader { | 369 abstract class SeekingReader { |
349 static const String serviceName = null; | 370 static const String serviceName = null; |
350 | 371 |
351 static service_describer.ServiceDescription _cachedServiceDescription; | 372 static service_describer.ServiceDescription _cachedServiceDescription; |
352 static service_describer.ServiceDescription get serviceDescription { | 373 static service_describer.ServiceDescription get serviceDescription { |
353 if (_cachedServiceDescription == null) { | 374 if (_cachedServiceDescription == null) { |
354 _cachedServiceDescription = new _SeekingReaderServiceDescription(); | 375 _cachedServiceDescription = new _SeekingReaderServiceDescription(); |
355 } | 376 } |
356 return _cachedServiceDescription; | 377 return _cachedServiceDescription; |
357 } | 378 } |
358 | 379 |
359 static SeekingReaderProxy connectToService( | 380 static SeekingReaderProxy connectToService( |
360 bindings.ServiceConnector s, String url, [String serviceName]) { | 381 bindings.ServiceConnector s, String url, [String serviceName]) { |
361 SeekingReaderProxy p = new SeekingReaderProxy.unbound(); | 382 SeekingReaderProxy p = new SeekingReaderProxy.unbound(); |
362 String name = serviceName ?? SeekingReader.serviceName; | 383 String name = serviceName ?? SeekingReader.serviceName; |
363 if ((name == null) || name.isEmpty) { | 384 if ((name == null) || name.isEmpty) { |
364 throw new core.MojoApiError( | 385 throw new core.MojoApiError( |
365 "If an interface has no ServiceName, then one must be provided."); | 386 "If an interface has no ServiceName, then one must be provided."); |
366 } | 387 } |
367 s.connectToService(url, p, name); | 388 s.connectToService(url, p, name); |
368 return p; | 389 return p; |
369 } | 390 } |
370 dynamic describe([Function responseFactory = null]); | 391 void describe(void callback(media_common_mojom.MediaResult result, int size, b
ool canSeek)); |
371 dynamic readAt(int position,[Function responseFactory = null]); | 392 void readAt(int position,void callback(media_common_mojom.MediaResult result,
core.MojoDataPipeConsumer dataPipe)); |
372 static const int kUnknownSize = 18446744073709551615; | 393 static const int kUnknownSize = 18446744073709551615; |
373 } | 394 } |
374 | 395 |
375 abstract class SeekingReaderInterface | 396 abstract class SeekingReaderInterface |
376 implements bindings.MojoInterface<SeekingReader>, | 397 implements bindings.MojoInterface<SeekingReader>, |
377 SeekingReader { | 398 SeekingReader { |
378 factory SeekingReaderInterface([SeekingReader impl]) => | 399 factory SeekingReaderInterface([SeekingReader impl]) => |
379 new SeekingReaderStub.unbound(impl); | 400 new SeekingReaderStub.unbound(impl); |
380 | 401 |
381 factory SeekingReaderInterface.fromEndpoint( | 402 factory SeekingReaderInterface.fromEndpoint( |
(...skipping 30 matching lines...) Expand all Loading... |
412 | 433 |
413 void handleResponse(bindings.ServiceMessage message) { | 434 void handleResponse(bindings.ServiceMessage message) { |
414 switch (message.header.type) { | 435 switch (message.header.type) { |
415 case _seekingReaderMethodDescribeName: | 436 case _seekingReaderMethodDescribeName: |
416 var r = SeekingReaderDescribeResponseParams.deserialize( | 437 var r = SeekingReaderDescribeResponseParams.deserialize( |
417 message.payload); | 438 message.payload); |
418 if (!message.header.hasRequestId) { | 439 if (!message.header.hasRequestId) { |
419 proxyError("Expected a message with a valid request Id."); | 440 proxyError("Expected a message with a valid request Id."); |
420 return; | 441 return; |
421 } | 442 } |
422 Completer c = completerMap[message.header.requestId]; | 443 Function callback = callbackMap[message.header.requestId]; |
423 if (c == null) { | 444 if (callback == null) { |
424 proxyError( | 445 proxyError( |
425 "Message had unknown request Id: ${message.header.requestId}"); | 446 "Message had unknown request Id: ${message.header.requestId}"); |
426 return; | 447 return; |
427 } | 448 } |
428 completerMap.remove(message.header.requestId); | 449 callbackMap.remove(message.header.requestId); |
429 if (c.isCompleted) { | 450 callback(r.result , r.size , r.canSeek ); |
430 proxyError("Response completer already completed"); | |
431 return; | |
432 } | |
433 c.complete(r); | |
434 break; | 451 break; |
435 case _seekingReaderMethodReadAtName: | 452 case _seekingReaderMethodReadAtName: |
436 var r = SeekingReaderReadAtResponseParams.deserialize( | 453 var r = SeekingReaderReadAtResponseParams.deserialize( |
437 message.payload); | 454 message.payload); |
438 if (!message.header.hasRequestId) { | 455 if (!message.header.hasRequestId) { |
439 proxyError("Expected a message with a valid request Id."); | 456 proxyError("Expected a message with a valid request Id."); |
440 return; | 457 return; |
441 } | 458 } |
442 Completer c = completerMap[message.header.requestId]; | 459 Function callback = callbackMap[message.header.requestId]; |
443 if (c == null) { | 460 if (callback == null) { |
444 proxyError( | 461 proxyError( |
445 "Message had unknown request Id: ${message.header.requestId}"); | 462 "Message had unknown request Id: ${message.header.requestId}"); |
446 return; | 463 return; |
447 } | 464 } |
448 completerMap.remove(message.header.requestId); | 465 callbackMap.remove(message.header.requestId); |
449 if (c.isCompleted) { | 466 callback(r.result , r.dataPipe ); |
450 proxyError("Response completer already completed"); | |
451 return; | |
452 } | |
453 c.complete(r); | |
454 break; | 467 break; |
455 default: | 468 default: |
456 proxyError("Unexpected message type: ${message.header.type}"); | 469 proxyError("Unexpected message type: ${message.header.type}"); |
457 close(immediate: true); | 470 close(immediate: true); |
458 break; | 471 break; |
459 } | 472 } |
460 } | 473 } |
461 | 474 |
462 @override | 475 @override |
463 String toString() { | 476 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
488 return newMockedProxy; | 501 return newMockedProxy; |
489 } | 502 } |
490 | 503 |
491 static SeekingReaderProxy newFromEndpoint( | 504 static SeekingReaderProxy newFromEndpoint( |
492 core.MojoMessagePipeEndpoint endpoint) { | 505 core.MojoMessagePipeEndpoint endpoint) { |
493 assert(endpoint.setDescription("For SeekingReaderProxy")); | 506 assert(endpoint.setDescription("For SeekingReaderProxy")); |
494 return new SeekingReaderProxy.fromEndpoint(endpoint); | 507 return new SeekingReaderProxy.fromEndpoint(endpoint); |
495 } | 508 } |
496 | 509 |
497 | 510 |
498 dynamic describe([Function responseFactory = null]) { | 511 void describe(void callback(media_common_mojom.MediaResult result, int size, b
ool canSeek)) { |
499 if (impl != null) { | 512 if (impl != null) { |
500 return new Future(() => impl.describe(_SeekingReaderStubControl._seekingRe
aderDescribeResponseParamsFactory)); | 513 impl.describe(callback); |
| 514 return; |
501 } | 515 } |
502 var params = new _SeekingReaderDescribeParams(); | 516 var params = new _SeekingReaderDescribeParams(); |
503 return ctrl.sendMessageWithRequestId( | 517 ctrl.sendMessageWithRequestId( |
504 params, | 518 params, |
505 _seekingReaderMethodDescribeName, | 519 _seekingReaderMethodDescribeName, |
506 -1, | 520 -1, |
507 bindings.MessageHeader.kMessageExpectsResponse); | 521 bindings.MessageHeader.kMessageExpectsResponse, |
| 522 callback); |
508 } | 523 } |
509 dynamic readAt(int position,[Function responseFactory = null]) { | 524 void readAt(int position,void callback(media_common_mojom.MediaResult result,
core.MojoDataPipeConsumer dataPipe)) { |
510 if (impl != null) { | 525 if (impl != null) { |
511 return new Future(() => impl.readAt(position,_SeekingReaderStubControl._se
ekingReaderReadAtResponseParamsFactory)); | 526 impl.readAt(position,callback); |
| 527 return; |
512 } | 528 } |
513 var params = new _SeekingReaderReadAtParams(); | 529 var params = new _SeekingReaderReadAtParams(); |
514 params.position = position; | 530 params.position = position; |
515 return ctrl.sendMessageWithRequestId( | 531 ctrl.sendMessageWithRequestId( |
516 params, | 532 params, |
517 _seekingReaderMethodReadAtName, | 533 _seekingReaderMethodReadAtName, |
518 -1, | 534 -1, |
519 bindings.MessageHeader.kMessageExpectsResponse); | 535 bindings.MessageHeader.kMessageExpectsResponse, |
| 536 callback); |
520 } | 537 } |
521 } | 538 } |
522 | 539 |
523 class _SeekingReaderStubControl | 540 class _SeekingReaderStubControl |
524 extends bindings.StubMessageHandler | 541 extends bindings.StubMessageHandler |
525 implements bindings.StubControl<SeekingReader> { | 542 implements bindings.StubControl<SeekingReader> { |
526 SeekingReader _impl; | 543 SeekingReader _impl; |
527 | 544 |
528 _SeekingReaderStubControl.fromEndpoint( | 545 _SeekingReaderStubControl.fromEndpoint( |
529 core.MojoMessagePipeEndpoint endpoint, [SeekingReader impl]) | 546 core.MojoMessagePipeEndpoint endpoint, [SeekingReader impl]) |
530 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 547 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
531 _impl = impl; | 548 _impl = impl; |
532 } | 549 } |
533 | 550 |
534 _SeekingReaderStubControl.fromHandle( | 551 _SeekingReaderStubControl.fromHandle( |
535 core.MojoHandle handle, [SeekingReader impl]) | 552 core.MojoHandle handle, [SeekingReader impl]) |
536 : super.fromHandle(handle, autoBegin: impl != null) { | 553 : super.fromHandle(handle, autoBegin: impl != null) { |
537 _impl = impl; | 554 _impl = impl; |
538 } | 555 } |
539 | 556 |
540 _SeekingReaderStubControl.unbound([this._impl]) : super.unbound(); | 557 _SeekingReaderStubControl.unbound([this._impl]) : super.unbound(); |
541 | 558 |
542 String get serviceName => SeekingReader.serviceName; | 559 String get serviceName => SeekingReader.serviceName; |
543 | 560 |
544 | 561 |
545 static SeekingReaderDescribeResponseParams _seekingReaderDescribeResponseParam
sFactory(media_common_mojom.MediaResult result, int size, bool canSeek) { | 562 Function _seekingReaderDescribeResponseParamsResponder( |
546 var result = new SeekingReaderDescribeResponseParams(); | 563 int requestId) { |
547 result.result = result; | 564 return (media_common_mojom.MediaResult result, int size, bool canSeek) { |
548 result.size = size; | 565 var result = new SeekingReaderDescribeResponseParams(); |
549 result.canSeek = canSeek; | 566 result.result = result; |
550 return result; | 567 result.size = size; |
| 568 result.canSeek = canSeek; |
| 569 sendResponse(buildResponseWithId( |
| 570 result, |
| 571 _seekingReaderMethodDescribeName, |
| 572 requestId, |
| 573 bindings.MessageHeader.kMessageIsResponse)); |
| 574 }; |
551 } | 575 } |
552 static SeekingReaderReadAtResponseParams _seekingReaderReadAtResponseParamsFac
tory(media_common_mojom.MediaResult result, core.MojoDataPipeConsumer dataPipe)
{ | 576 Function _seekingReaderReadAtResponseParamsResponder( |
553 var result = new SeekingReaderReadAtResponseParams(); | 577 int requestId) { |
554 result.result = result; | 578 return (media_common_mojom.MediaResult result, core.MojoDataPipeConsumer dataP
ipe) { |
555 result.dataPipe = dataPipe; | 579 var result = new SeekingReaderReadAtResponseParams(); |
556 return result; | 580 result.result = result; |
| 581 result.dataPipe = dataPipe; |
| 582 sendResponse(buildResponseWithId( |
| 583 result, |
| 584 _seekingReaderMethodReadAtName, |
| 585 requestId, |
| 586 bindings.MessageHeader.kMessageIsResponse)); |
| 587 }; |
557 } | 588 } |
558 | 589 |
559 dynamic handleMessage(bindings.ServiceMessage message) { | 590 void handleMessage(bindings.ServiceMessage message) { |
560 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 591 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
561 return bindings.ControlMessageHandler.handleMessage(this, | 592 bindings.ControlMessageHandler.handleMessage( |
562 0, | 593 this, 0, message); |
563 message); | 594 return; |
564 } | 595 } |
565 if (_impl == null) { | 596 if (_impl == null) { |
566 throw new core.MojoApiError("$this has no implementation set"); | 597 throw new core.MojoApiError("$this has no implementation set"); |
567 } | 598 } |
568 switch (message.header.type) { | 599 switch (message.header.type) { |
569 case _seekingReaderMethodDescribeName: | 600 case _seekingReaderMethodDescribeName: |
570 var response = _impl.describe(_seekingReaderDescribeResponseParamsFactor
y); | 601 _impl.describe(_seekingReaderDescribeResponseParamsResponder(message.hea
der.requestId)); |
571 if (response is Future) { | |
572 return response.then((response) { | |
573 if (response != null) { | |
574 return buildResponseWithId( | |
575 response, | |
576 _seekingReaderMethodDescribeName, | |
577 message.header.requestId, | |
578 bindings.MessageHeader.kMessageIsResponse); | |
579 } | |
580 }); | |
581 } else if (response != null) { | |
582 return buildResponseWithId( | |
583 response, | |
584 _seekingReaderMethodDescribeName, | |
585 message.header.requestId, | |
586 bindings.MessageHeader.kMessageIsResponse); | |
587 } | |
588 break; | 602 break; |
589 case _seekingReaderMethodReadAtName: | 603 case _seekingReaderMethodReadAtName: |
590 var params = _SeekingReaderReadAtParams.deserialize( | 604 var params = _SeekingReaderReadAtParams.deserialize( |
591 message.payload); | 605 message.payload); |
592 var response = _impl.readAt(params.position,_seekingReaderReadAtResponse
ParamsFactory); | 606 _impl.readAt(params.position, _seekingReaderReadAtResponseParamsResponde
r(message.header.requestId)); |
593 if (response is Future) { | |
594 return response.then((response) { | |
595 if (response != null) { | |
596 return buildResponseWithId( | |
597 response, | |
598 _seekingReaderMethodReadAtName, | |
599 message.header.requestId, | |
600 bindings.MessageHeader.kMessageIsResponse); | |
601 } | |
602 }); | |
603 } else if (response != null) { | |
604 return buildResponseWithId( | |
605 response, | |
606 _seekingReaderMethodReadAtName, | |
607 message.header.requestId, | |
608 bindings.MessageHeader.kMessageIsResponse); | |
609 } | |
610 break; | 607 break; |
611 default: | 608 default: |
612 throw new bindings.MojoCodecError("Unexpected message name"); | 609 throw new bindings.MojoCodecError("Unexpected message name"); |
613 break; | 610 break; |
614 } | 611 } |
615 return null; | |
616 } | 612 } |
617 | 613 |
618 SeekingReader get impl => _impl; | 614 SeekingReader get impl => _impl; |
619 set impl(SeekingReader d) { | 615 set impl(SeekingReader d) { |
620 if (d == null) { | 616 if (d == null) { |
621 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 617 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
622 } | 618 } |
623 if (isBound && (_impl == null)) { | 619 if (isBound && (_impl == null)) { |
624 beginHandlingEvents(); | 620 beginHandlingEvents(); |
625 } | 621 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
659 core.MojoHandle handle, [SeekingReader impl]) | 655 core.MojoHandle handle, [SeekingReader impl]) |
660 : super(new _SeekingReaderStubControl.fromHandle(handle, impl)); | 656 : super(new _SeekingReaderStubControl.fromHandle(handle, impl)); |
661 | 657 |
662 static SeekingReaderStub newFromEndpoint( | 658 static SeekingReaderStub newFromEndpoint( |
663 core.MojoMessagePipeEndpoint endpoint) { | 659 core.MojoMessagePipeEndpoint endpoint) { |
664 assert(endpoint.setDescription("For SeekingReaderStub")); | 660 assert(endpoint.setDescription("For SeekingReaderStub")); |
665 return new SeekingReaderStub.fromEndpoint(endpoint); | 661 return new SeekingReaderStub.fromEndpoint(endpoint); |
666 } | 662 } |
667 | 663 |
668 | 664 |
669 dynamic describe([Function responseFactory = null]) { | 665 void describe(void callback(media_common_mojom.MediaResult result, int size, b
ool canSeek)) { |
670 return impl.describe(responseFactory); | 666 return impl.describe(callback); |
671 } | 667 } |
672 dynamic readAt(int position,[Function responseFactory = null]) { | 668 void readAt(int position,void callback(media_common_mojom.MediaResult result,
core.MojoDataPipeConsumer dataPipe)) { |
673 return impl.readAt(position,responseFactory); | 669 return impl.readAt(position,callback); |
674 } | 670 } |
675 } | 671 } |
676 | 672 |
677 | 673 |
678 | 674 |
OLD | NEW |