OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 library media_sink_mojom; | 5 library media_sink_mojom; |
6 import 'dart:async'; | 6 import 'dart:async'; |
7 import 'package:mojo/bindings.dart' as bindings; | 7 import 'package:mojo/bindings.dart' as bindings; |
8 import 'package:mojo/core.dart' as core; | 8 import 'package:mojo/core.dart' as core; |
9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
10 import 'package:mojo_services/mojo/media/media_state.mojom.dart' as media_state_
mojom; | 10 import 'package:mojo_services/mojo/media/media_state.mojom.dart' as media_state_
mojom; |
(...skipping 456 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
467 | 467 |
468 abstract class MediaSink { | 468 abstract class MediaSink { |
469 static const String serviceName = null; | 469 static const String serviceName = null; |
470 void getConsumer(Object consumer); | 470 void getConsumer(Object consumer); |
471 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]); | 471 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]); |
472 void play(); | 472 void play(); |
473 void pause(); | 473 void pause(); |
474 static const int kInitialStatus = 0; | 474 static const int kInitialStatus = 0; |
475 } | 475 } |
476 | 476 |
477 | 477 class _MediaSinkProxyControl |
478 class _MediaSinkProxyControl extends bindings.ProxyMessageHandler | 478 extends bindings.ProxyMessageHandler |
479 implements bindings.ProxyControl { | 479 implements bindings.ProxyControl { |
480 _MediaSinkProxyControl.fromEndpoint( | 480 _MediaSinkProxyControl.fromEndpoint( |
481 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); | 481 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
482 | 482 |
483 _MediaSinkProxyControl.fromHandle( | 483 _MediaSinkProxyControl.fromHandle( |
484 core.MojoHandle handle) : super.fromHandle(handle); | 484 core.MojoHandle handle) : super.fromHandle(handle); |
485 | 485 |
486 _MediaSinkProxyControl.unbound() : super.unbound(); | 486 _MediaSinkProxyControl.unbound() : super.unbound(); |
487 | 487 |
488 service_describer.ServiceDescription get serviceDescription => | 488 service_describer.ServiceDescription get serviceDescription => |
489 new _MediaSinkServiceDescription(); | 489 new _MediaSinkServiceDescription(); |
490 | 490 |
491 String get serviceName => MediaSink.serviceName; | 491 String get serviceName => MediaSink.serviceName; |
492 | 492 |
493 @override | |
494 void handleResponse(bindings.ServiceMessage message) { | 493 void handleResponse(bindings.ServiceMessage message) { |
495 switch (message.header.type) { | 494 switch (message.header.type) { |
496 case _mediaSinkMethodGetStatusName: | 495 case _mediaSinkMethodGetStatusName: |
497 var r = MediaSinkGetStatusResponseParams.deserialize( | 496 var r = MediaSinkGetStatusResponseParams.deserialize( |
498 message.payload); | 497 message.payload); |
499 if (!message.header.hasRequestId) { | 498 if (!message.header.hasRequestId) { |
500 proxyError("Expected a message with a valid request Id."); | 499 proxyError("Expected a message with a valid request Id."); |
501 return; | 500 return; |
502 } | 501 } |
503 Completer c = completerMap[message.header.requestId]; | 502 Completer c = completerMap[message.header.requestId]; |
(...skipping 16 matching lines...) Expand all Loading... |
520 } | 519 } |
521 } | 520 } |
522 | 521 |
523 @override | 522 @override |
524 String toString() { | 523 String toString() { |
525 var superString = super.toString(); | 524 var superString = super.toString(); |
526 return "_MediaSinkProxyControl($superString)"; | 525 return "_MediaSinkProxyControl($superString)"; |
527 } | 526 } |
528 } | 527 } |
529 | 528 |
530 | 529 class MediaSinkProxy |
531 class MediaSinkProxy extends bindings.Proxy | 530 extends bindings.Proxy |
532 implements MediaSink { | 531 implements MediaSink { |
533 MediaSinkProxy.fromEndpoint( | 532 MediaSinkProxy.fromEndpoint( |
534 core.MojoMessagePipeEndpoint endpoint) | 533 core.MojoMessagePipeEndpoint endpoint) |
535 : super(new _MediaSinkProxyControl.fromEndpoint(endpoint)); | 534 : super(new _MediaSinkProxyControl.fromEndpoint(endpoint)); |
536 | 535 |
537 MediaSinkProxy.fromHandle(core.MojoHandle handle) | 536 MediaSinkProxy.fromHandle(core.MojoHandle handle) |
538 : super(new _MediaSinkProxyControl.fromHandle(handle)); | 537 : super(new _MediaSinkProxyControl.fromHandle(handle)); |
539 | 538 |
540 MediaSinkProxy.unbound() | 539 MediaSinkProxy.unbound() |
541 : super(new _MediaSinkProxyControl.unbound()); | 540 : super(new _MediaSinkProxyControl.unbound()); |
542 | 541 |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
586 if (!ctrl.isBound) { | 585 if (!ctrl.isBound) { |
587 ctrl.proxyError("The Proxy is closed."); | 586 ctrl.proxyError("The Proxy is closed."); |
588 return; | 587 return; |
589 } | 588 } |
590 var params = new _MediaSinkPauseParams(); | 589 var params = new _MediaSinkPauseParams(); |
591 ctrl.sendMessage(params, | 590 ctrl.sendMessage(params, |
592 _mediaSinkMethodPauseName); | 591 _mediaSinkMethodPauseName); |
593 } | 592 } |
594 } | 593 } |
595 | 594 |
596 | 595 class _MediaSinkStubControl |
597 class MediaSinkStub extends bindings.Stub { | 596 extends bindings.StubMessageHandler |
| 597 implements bindings.StubControl<MediaSink> { |
598 MediaSink _impl; | 598 MediaSink _impl; |
599 | 599 |
600 MediaSinkStub.fromEndpoint( | 600 _MediaSinkStubControl.fromEndpoint( |
601 core.MojoMessagePipeEndpoint endpoint, [MediaSink impl]) | 601 core.MojoMessagePipeEndpoint endpoint, [MediaSink impl]) |
602 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 602 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
603 _impl = impl; | 603 _impl = impl; |
604 } | 604 } |
605 | 605 |
606 MediaSinkStub.fromHandle( | 606 _MediaSinkStubControl.fromHandle( |
607 core.MojoHandle handle, [MediaSink impl]) | 607 core.MojoHandle handle, [MediaSink impl]) |
608 : super.fromHandle(handle, autoBegin: impl != null) { | 608 : super.fromHandle(handle, autoBegin: impl != null) { |
609 _impl = impl; | 609 _impl = impl; |
610 } | 610 } |
611 | 611 |
612 MediaSinkStub.unbound([this._impl]) : super.unbound(); | 612 _MediaSinkStubControl.unbound([this._impl]) : super.unbound(); |
613 | |
614 static MediaSinkStub newFromEndpoint( | |
615 core.MojoMessagePipeEndpoint endpoint) { | |
616 assert(endpoint.setDescription("For MediaSinkStub")); | |
617 return new MediaSinkStub.fromEndpoint(endpoint); | |
618 } | |
619 | 613 |
620 | 614 |
621 MediaSinkGetStatusResponseParams _mediaSinkGetStatusResponseParamsFactory(int
version, MediaSinkStatus status) { | 615 MediaSinkGetStatusResponseParams _mediaSinkGetStatusResponseParamsFactory(int
version, MediaSinkStatus status) { |
622 var result = new MediaSinkGetStatusResponseParams(); | 616 var result = new MediaSinkGetStatusResponseParams(); |
623 result.version = version; | 617 result.version = version; |
624 result.status = status; | 618 result.status = status; |
625 return result; | 619 return result; |
626 } | 620 } |
627 | 621 |
628 dynamic handleMessage(bindings.ServiceMessage message) { | 622 dynamic handleMessage(bindings.ServiceMessage message) { |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
687 } | 681 } |
688 | 682 |
689 @override | 683 @override |
690 void bind(core.MojoMessagePipeEndpoint endpoint) { | 684 void bind(core.MojoMessagePipeEndpoint endpoint) { |
691 super.bind(endpoint); | 685 super.bind(endpoint); |
692 if (!isOpen && (_impl != null)) { | 686 if (!isOpen && (_impl != null)) { |
693 beginHandlingEvents(); | 687 beginHandlingEvents(); |
694 } | 688 } |
695 } | 689 } |
696 | 690 |
| 691 @override |
697 String toString() { | 692 String toString() { |
698 var superString = super.toString(); | 693 var superString = super.toString(); |
699 return "MediaSinkStub($superString)"; | 694 return "_MediaSinkStubControl($superString)"; |
700 } | 695 } |
701 | 696 |
702 int get version => 0; | 697 int get version => 0; |
703 | 698 |
704 static service_describer.ServiceDescription _cachedServiceDescription; | 699 static service_describer.ServiceDescription _cachedServiceDescription; |
705 static service_describer.ServiceDescription get serviceDescription { | 700 static service_describer.ServiceDescription get serviceDescription { |
706 if (_cachedServiceDescription == null) { | 701 if (_cachedServiceDescription == null) { |
707 _cachedServiceDescription = new _MediaSinkServiceDescription(); | 702 _cachedServiceDescription = new _MediaSinkServiceDescription(); |
708 } | 703 } |
709 return _cachedServiceDescription; | 704 return _cachedServiceDescription; |
710 } | 705 } |
711 } | 706 } |
712 | 707 |
| 708 class MediaSinkStub |
| 709 extends bindings.Stub<MediaSink> |
| 710 implements MediaSink { |
| 711 MediaSinkStub.fromEndpoint( |
| 712 core.MojoMessagePipeEndpoint endpoint, [MediaSink impl]) |
| 713 : super(new _MediaSinkStubControl.fromEndpoint(endpoint, impl)); |
| 714 |
| 715 MediaSinkStub.fromHandle( |
| 716 core.MojoHandle handle, [MediaSink impl]) |
| 717 : super(new _MediaSinkStubControl.fromHandle(handle, impl)); |
| 718 |
| 719 MediaSinkStub.unbound([MediaSink impl]) |
| 720 : super(new _MediaSinkStubControl.unbound(impl)); |
| 721 |
| 722 static MediaSinkStub newFromEndpoint( |
| 723 core.MojoMessagePipeEndpoint endpoint) { |
| 724 assert(endpoint.setDescription("For MediaSinkStub")); |
| 725 return new MediaSinkStub.fromEndpoint(endpoint); |
| 726 } |
| 727 |
| 728 static service_describer.ServiceDescription get serviceDescription => |
| 729 _MediaSinkStubControl.serviceDescription; |
| 730 |
| 731 |
| 732 void getConsumer(Object consumer) { |
| 733 return impl.getConsumer(consumer); |
| 734 } |
| 735 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]) { |
| 736 return impl.getStatus(versionLastSeen,responseFactory); |
| 737 } |
| 738 void play() { |
| 739 return impl.play(); |
| 740 } |
| 741 void pause() { |
| 742 return impl.pause(); |
| 743 } |
| 744 } |
| 745 |
713 | 746 |
714 | 747 |
OLD | NEW |