Searched refs:MessageReceiver (Results 1 - 25 of 34) sorted by relevance

12

/external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
H A DMessageReceiverWithResponder.java8 * A {@link MessageReceiver} that can also handle the handle the response message generated from the
11 public interface MessageReceiverWithResponder extends MessageReceiver {
14 * A variant on {@link #accept(Message)} that registers a {@link MessageReceiver}
17 * {@link #acceptWithResponder(Message, MessageReceiver)}, or some time after its
20 boolean acceptWithResponder(Message message, MessageReceiver responder);
H A DMessageReceiver.java12 public interface MessageReceiver extends Closeable { interface in inherits:Closeable
15 * Receive a {@link Message}. The {@link MessageReceiver} is allowed to mutate the message.
H A DRouterImpl.java24 * {@link MessageReceiver} used as the {@link Connector} callback.
26 private class HandleIncomingMessageThunk implements MessageReceiver {
29 * @see MessageReceiver#accept(Message)
37 * @see MessageReceiver#close()
48 * {@link MessageReceiver} used to return responses to the caller.
50 class ResponderThunk implements MessageReceiver {
55 * MessageReceiver#accept(Message)
64 * @see MessageReceiver#close()
100 * The map from request ids to {@link MessageReceiver} of request currently in flight.
102 private Map<Long, MessageReceiver> mResponder
[all...]
H A DConnector.java19 * registered {@link MessageReceiver}. It also acts as a {@link MessageReceiver} and will send any
25 public class Connector implements MessageReceiver, HandleOwner<MessagePipeHandle> {
43 * The {@link MessageReceiver} to which received messages are sent.
45 private MessageReceiver mIncomingMessageReceiver;
76 * Set the {@link MessageReceiver} that will receive message from the owned message pipe.
78 public void setIncomingMessageReceiver(MessageReceiver incomingMessageReceiver) {
99 * @see MessageReceiver#accept(Message)
137 MessageReceiver incomingMessageReceiver = mIncomingMessageReceiver;
225 * Read a message, and pass it to the given |MessageReceiver| i
[all...]
H A DInterfaceControlMessagesHelper.java18 * MessageReceiver that forwards a message containing a {@link RunResponseMessageParams} to a
22 extends SideEffectFreeCloseable implements MessageReceiver {
30 * @see MessageReceiver#accept(Message)
66 Core core, Manager<I, P> manager, ServiceMessage message, MessageReceiver responder) {
/external/libmojo/mojo/public/cpp/bindings/
H A Dmessage_filter.h13 // implement the pure virtual method Accept() inherited from MessageReceiver to
15 class MessageFilter : public MessageReceiver {
19 explicit MessageFilter(MessageReceiver* sink = nullptr);
22 void set_sink(MessageReceiver* sink) { sink_ = sink; }
25 MessageReceiver* sink_;
31 explicit PassThroughFilter(MessageReceiver* sink = nullptr);
H A Dpipe_control_message_proxy.h14 class MessageReceiver;
20 explicit PipeControlMessageProxy(MessageReceiver* receiver);
27 MessageReceiver* receiver_;
H A Dmessage_header_validator.h15 explicit MessageHeaderValidator(MessageReceiver* sink = nullptr);
17 MessageReceiver* sink = nullptr);
H A Dno_interface.h32 explicit NoInterfaceProxy(MessageReceiver* receiver) {}
42 MessageReceiver* responder) override;
H A Dmessage.h120 class MessageReceiver { class in namespace:mojo
122 virtual ~MessageReceiver() {}
130 class MessageReceiverWithResponder : public MessageReceiver {
134 // A variant on Accept that registers a MessageReceiver (known as the
144 // std::unique_ptr<MessageReceiver>.
145 virtual bool AcceptWithResponder(Message* message, MessageReceiver* responder)
149 // A MessageReceiver that is also able to provide status about the state
152 class MessageReceiverWithStatus : public MessageReceiver {
156 // Returns |true| if this MessageReceiver is currently bound to a MessagePipe,
160 // DCHECKs if this MessageReceiver i
[all...]
H A Dconnector.h27 // MessagePipe. It writes messages it receives through the MessageReceiver
29 // MessageReceiver interface assigned as its incoming receiver.
36 class Connector : public MessageReceiver {
54 void set_incoming_receiver(MessageReceiver* receiver) {
118 // MessageReceiver implementation:
178 MessageReceiver* incoming_receiver_;
H A Dpipe_control_message_handler.h18 class PipeControlMessageHandler : public MessageReceiver {
31 // MessageReceiver implementation:
H A Dinterface_endpoint_client.h79 MessageReceiver* responder) override;
89 // Maps from the id of a response to the MessageReceiver that handles the
92 std::map<uint64_t, std::unique_ptr<MessageReceiver>>;
112 class HandleIncomingMessageThunk : public MessageReceiver {
117 // MessageReceiver implementation:
/external/libmojo/mojo/public/cpp/bindings/lib/
H A Dno_interface.cc16 MessageReceiver* responder) {
H A Dmessage_filter.cc9 MessageFilter::MessageFilter(MessageReceiver* sink) : sink_(sink) {
15 PassThroughFilter::PassThroughFilter(MessageReceiver* sink)
H A Dfilter_chain.h22 explicit FilterChain(MessageReceiver* sink = nullptr);
33 void SetSink(MessageReceiver* sink);
39 MessageReceiver* GetHead();
46 MessageReceiver* sink_;
H A Dfilter_chain.cc14 FilterChain::FilterChain(MessageReceiver* sink) : sink_(sink) {
36 void FilterChain::SetSink(MessageReceiver* sink) {
43 MessageReceiver* FilterChain::GetHead() {
H A Dmessage_header_validator.cc68 MessageHeaderValidator::MessageHeaderValidator(MessageReceiver* sink)
72 MessageReceiver* sink)
H A Drouter.h79 // MessageReceiver implementation:
82 MessageReceiver* responder) override;
117 // Maps from the id of a response to the MessageReceiver that handles the
120 std::map<uint64_t, std::unique_ptr<MessageReceiver>>;
138 class HandleIncomingMessageThunk : public MessageReceiver {
143 // MessageReceiver implementation:
H A Dpipe_control_message_proxy.cc20 void SendRunOrClosePipeMessage(MessageReceiver* receiver,
45 PipeControlMessageProxy::PipeControlMessageProxy(MessageReceiver* receiver)
H A Dcontrol_message_proxy.cc25 class RunResponseForwardToCallback : public MessageReceiver {
63 MessageReceiver* responder = new RunResponseForwardToCallback(callback);
/external/libmojo/mojo/android/javatests/src/org/chromium/mojo/bindings/test/mojom/mojo/
H A DIntegrationTestInterfaceTestHelper.java7 import org.chromium.mojo.bindings.MessageReceiver;
24 * Creates a new {@link MessageReceiver} to use for the callback of
27 public static MessageReceiver newIntegrationTestInterfaceMethodCallback() {
/external/libmojo/mojo/android/javatests/src/org/chromium/mojo/bindings/
H A DBindingsTestUtils.java25 * {@link MessageReceiver} that records any message it receives.
28 implements MessageReceiver {
33 * @see MessageReceiver#accept(Message)
48 public final List<Pair<Message, MessageReceiver>> messagesWithReceivers =
49 new ArrayList<Pair<Message, MessageReceiver>>();
52 * @see MessageReceiverWithResponder#acceptWithResponder(Message, MessageReceiver)
55 public boolean acceptWithResponder(Message message, MessageReceiver responder) {
H A DValidationTest.java104 * Runs all the test with the given prefix on the given {@link MessageReceiver}.
106 private static void runTest(String prefix, MessageReceiver messageReceiver)
131 private static class RoutingMessageReceiver implements MessageReceiver {
133 private final MessageReceiver mResponse;
136 MessageReceiver response) {
142 * @see MessageReceiver#accept(Message)
159 * @see MessageReceiver#close()
182 public boolean acceptWithResponder(Message message, MessageReceiver responder) {
/external/libmojo/mojo/public/cpp/bindings/tests/
H A Drouter_test_util.h26 class MessageAccumulator : public MessageReceiver {
51 MessageReceiver* responder);

Completed in 935 milliseconds

12