Home
last modified time | relevance | path

Searched refs:messageProducer (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DApplicationThreadDeframerTest.java124 MultiMessageProducer messageProducer = new MultiMessageProducer(messages); in messagesAvailableDrainsToMessageReadQueue_returnedByInitializingMessageProducer() local
125 applicationThreadDeframer.messagesAvailable(messageProducer); in messagesAvailableDrainsToMessageReadQueue_returnedByInitializingMessageProducer()
DRetriableStreamTest.java819 MessageProducer messageProducer = mock(MessageProducer.class); in messageAvailable() local
820 listener.messagesAvailable(messageProducer); in messageAvailable()
821 verify(masterListener).messagesAvailable(messageProducer); in messageAvailable()