OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:MessageReceiver
(Results
1 - 25
of
52
) sorted by null
1
2
3
/external/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
MessageReceiverWithResponder.java
8
* 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);
MessageReceiver.java
12
public interface
MessageReceiver
extends Closeable {
15
* Receive a {@link Message}. The {@link
MessageReceiver
} is allowed to mutate the message.
RouterImpl.java
24
* {@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
> mResponders = new HashMap<Long, MessageReceiver>()
[
all
...]
Connector.java
19
* 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;
70
* Set the {@link
MessageReceiver
} that will receive message from the owned message pipe.
72
public void setIncomingMessageReceiver(
MessageReceiver
incomingMessageReceiver) {
92
* @see
MessageReceiver
#accept(Message)
130
MessageReceiver
incomingMessageReceiver = mIncomingMessageReceiver;
189
* Read a message, and pass it to the given |
MessageReceiver
| if not null. If th
[
all
...]
/external/libchrome/mojo/public/cpp/bindings/
pipe_control_message_proxy.h
18
class
MessageReceiver
;
27
explicit PipeControlMessageProxy(
MessageReceiver
* receiver);
38
MessageReceiver
* receiver_;
filter_chain.h
19
class MOJO_CPP_BINDINGS_EXPORT FilterChain : public
MessageReceiver
{
23
explicit FilterChain(
MessageReceiver
* sink = nullptr);
32
void Append(std::unique_ptr<
MessageReceiver
> filter);
36
void SetSink(
MessageReceiver
* sink);
38
//
MessageReceiver
:
42
std::vector<std::unique_ptr<
MessageReceiver
>> filters_;
44
MessageReceiver
* sink_;
message_header_validator.h
15
: public
MessageReceiver
{
message_dumper.h
14
class MessageDumper : public mojo::
MessageReceiver
{
pipe_control_message_handler.h
21
: public
MessageReceiver
{
34
//
MessageReceiver
implementation:
interface_endpoint_client.h
47
std::unique_ptr<
MessageReceiver
> payload_validator,
82
// Adds a
MessageReceiver
which can filter a message after validation but
84
void AddFilter(std::unique_ptr<
MessageReceiver
> filter);
101
std::unique_ptr<
MessageReceiver
> responder) override;
118
// Maps from the id of a response to the
MessageReceiver
that handles the
121
std::map<uint64_t, std::unique_ptr<
MessageReceiver
>>;
141
class HandleIncomingMessageThunk : public
MessageReceiver
{
146
//
MessageReceiver
implementation:
associated_binding.h
29
class
MessageReceiver
;
41
void AddFilter(std::unique_ptr<
MessageReceiver
> filter);
74
std::unique_ptr<
MessageReceiver
> payload_validator,
connector.h
33
// MessagePipe. It writes messages it receives through the
MessageReceiver
35
//
MessageReceiver
interface assigned as its incoming receiver.
42
class MOJO_CPP_BINDINGS_EXPORT Connector : public
MessageReceiver
{
93
void set_incoming_receiver(
MessageReceiver
* receiver) {
157
//
MessageReceiver
implementation:
232
MessageReceiver
* incoming_receiver_ = nullptr;
275
std::unique_ptr<
MessageReceiver
> message_dumper_;
message.h
251
class COMPONENT_EXPORT(MOJO_CPP_BINDINGS_BASE)
MessageReceiver
{
253
virtual ~
MessageReceiver
() {}
264
class MessageReceiverWithResponder : public
MessageReceiver
{
268
// A variant on Accept that registers a
MessageReceiver
(known as the
273
std::unique_ptr<
MessageReceiver
> responder)
277
// A
MessageReceiver
that is also able to provide status about the state
280
class MessageReceiverWithStatus : public
MessageReceiver
{
284
// Returns |true| if this
MessageReceiver
is currently bound to a MessagePipe,
288
// Determines if this
MessageReceiver
is still bound to a message pipe and has
298
class MessageReceiverWithResponderStatus : public
MessageReceiver
{
[
all
...]
thread_safe_interface_ptr.h
47
base::Callback<void(Message, std::unique_ptr<
MessageReceiver
>)>;
106
std::unique_ptr<
MessageReceiver
> responder) override {
181
// A
MessageReceiver
that signals |response| when it either accepts the
183
class SyncResponseSignaler : public
MessageReceiver
{
216
class ForwardToCallingThread : public
MessageReceiver
{
218
explicit ForwardToCallingThread(std::unique_ptr<
MessageReceiver
> responder)
239
std::unique_ptr<
MessageReceiver
> responder,
244
std::unique_ptr<
MessageReceiver
> responder_;
359
std::unique_ptr<
MessageReceiver
> responder) {
binding.h
25
class
MessageReceiver
;
107
void AddFilter(std::unique_ptr<
MessageReceiver
> filter) {
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/test/mojom/mojo/
IntegrationTestInterfaceTestHelper.java
7
import org.chromium.mojo.bindings.
MessageReceiver
;
22
* Creates a new {@link
MessageReceiver
} to use for the callback of
25
public static
MessageReceiver
newIntegrationTestInterfaceMethodCallback() {
/external/libchrome/mojo/public/cpp/bindings/lib/
filter_chain.cc
13
FilterChain::FilterChain(
MessageReceiver
* sink) : sink_(sink) {
30
void FilterChain::SetSink(
MessageReceiver
* sink) {
43
void FilterChain::Append(std::unique_ptr<
MessageReceiver
> filter) {
associated_binding.cc
16
void AssociatedBindingBase::AddFilter(std::unique_ptr<
MessageReceiver
> filter) {
52
std::unique_ptr<
MessageReceiver
> payload_validator,
associated_interface_ptr_state.h
75
std::unique_ptr<
MessageReceiver
> responder) {
83
std::unique_ptr<
MessageReceiver
> validator,
/development/apps/PushApiTestAppOne/src/com/example/android/pushapithirdpartyone/
MessageReceiver.java
25
public class
MessageReceiver
extends BroadcastReceiver {
/development/apps/PushApiTestAppTwo/src/com/example/android/pushapithirdpartytwo/
MessageReceiver.java
25
public class
MessageReceiver
extends BroadcastReceiver {
/development/apps/PushApiAuthenticator/src/com/example/android/pushapiauthenticator/
MessageReceiver.java
24
public class
MessageReceiver
extends BroadcastReceiver {
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/
BindingsTestUtils.java
24
* {@link
MessageReceiver
} that records any message it receives.
27
extends SideEffectFreeCloseable implements
MessageReceiver
{
31
* @see
MessageReceiver
#accept(Message)
45
public final List<Pair<Message,
MessageReceiver
>> messagesWithReceivers =
46
new ArrayList<Pair<Message,
MessageReceiver
>>();
49
* @see MessageReceiverWithResponder#acceptWithResponder(Message,
MessageReceiver
)
52
public boolean acceptWithResponder(Message message,
MessageReceiver
responder) {
ValidationTest.java
115
* Runs all the test with the given prefix on the given {@link
MessageReceiver
}.
117
private static void runTest(String prefix,
MessageReceiver
messageReceiver
)
129
boolean passed =
messageReceiver
.accept(message);
142
private static class RoutingMessageReceiver implements
MessageReceiver
{
144
private final
MessageReceiver
mResponse;
147
MessageReceiverWithResponder request,
MessageReceiver
response) {
153
* @see
MessageReceiver
#accept(Message)
170
* @see
MessageReceiver
#close()
189
public boolean acceptWithResponder(Message message,
MessageReceiver
responder)
[
all
...]
/external/libchrome/mojo/public/cpp/bindings/tests/
router_test_util.h
26
class MessageAccumulator : public
MessageReceiver
{
51
MessageReceiver
* responder);
Completed in 528 milliseconds
1
2
3