Searched refs:invokeInRemoteProcess (Results 1 – 10 of 10) sorted by relevance
38 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): Output { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.TwoWayIpcTest.MultiplyBy3Action48 assertThat(subject.invokeInRemoteProcess(MultiplyBy3Action(3))) in sample()54 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): ThrowingAction { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.TwoWayIpcTest.ThrowingAction64 val result = runCatching { subject.invokeInRemoteProcess(ThrowingAction()) } in exceptionThrown()74 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): Output { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.TwoWayIpcTest.ValueInRemoteAction91 assertThat(subject1.invokeInRemoteProcess(action).value).isEqualTo("b") in multipleSubjects()92 assertThat(subject2.invokeInRemoteProcess(action).value).isEqualTo("b") in multipleSubjects()94 assertThat(subject1.invokeInRemoteProcess(action.copy(value = "c")).value) in multipleSubjects()99 subject1.invokeInRemoteProcess(action.copy(value = "d", set = false)).value in multipleSubjects()104 subject2.invokeInRemoteProcess(action.copy(value = "d", set = false)).value in multipleSubjects()[all …]
133 subject1.invokeInRemoteProcess(SetTextAction("ds1-version-1")) in test()134 subject2.invokeInRemoteProcess(SetTextAction("ds2-version-1")) in test()140 subject1.invokeInRemoteProcess(subject1Observer) in test()145 subject2.invokeInRemoteProcess(subject2Observer) in test()161 subject1.invokeInRemoteProcess(SetTextAction(value = "ds1-version-3")) in test()164 assertThat(subject1.invokeInRemoteProcess(ReadRemoteObservedValue()).value) in test()167 assertThat(subject1.invokeInRemoteProcess(ReadTextAction()).value) in test()172 subject2.invokeInRemoteProcess(SetTextAction("ds2-version-3")) in test()201 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): IpcUnit { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.ObserveFileAction227 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): IpcUnit { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.AssertRemoteObservedValue[all …]
72 subject.invokeInRemoteProcess(SetTextAction("abc")) in testSimpleUpdateData_file()76 assertThat(subject.invokeInRemoteProcess(ReadTextAction()).value).isEqualTo("hostValue") in testSimpleUpdateData_file()102 subject1.invokeInRemoteProcess( in testConcurrentReadUpdate_file()114 assertThat(subject1.invokeInRemoteProcess(ReadTextAction()).value).isEqualTo("hostData") in testConcurrentReadUpdate_file()116 assertThat(subject2.invokeInRemoteProcess(ReadTextAction()).value).isEqualTo("hostData") in testConcurrentReadUpdate_file()121 assertThat(subject1.invokeInRemoteProcess(ReadTextAction()).value) in testConcurrentReadUpdate_file()123 assertThat(subject2.invokeInRemoteProcess(ReadTextAction()).value) in testConcurrentReadUpdate_file()147 subject.invokeInRemoteProcess( in testInterleavedUpdateData_file()194 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): IpcUnit { in testInterleavedUpdateDataWithLocalRead_file() method in androidx.datastore.testapp.multiprocess.MultiProcessDataStoreIpcTest.InterleavedDoubleUpdateAction219 val remoteActionExecution = async { subject.invokeInRemoteProcess(remoteAction) } in testInterleavedUpdateDataWithLocalRead()[all …]
43 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): IpcUnit { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.InterProcessCompletableTest.Complete57 subject.invokeInRemoteProcess( in completeInRemoteProcess()
41 val response = ipcAction.invokeInRemoteProcess(this) in handleIncomingAction()46 suspend fun <T : Parcelable> invokeInRemoteProcess(action: IpcAction<T>): T { in invokeInRemoteProcess() method in androidx.datastore.testapp.twoWayIpc.TwoWayIpcSubject
25 abstract suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): T method in androidx.datastore.testapp.twoWayIpc.IpcAction
70 subject.invokeInRemoteProcess(CompleteCompletableAction(key = key, value = value)) in complete()79 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): IpcUnit { in invokeInRemoteProcess() method in androidx.datastore.testapp.twoWayIpc.CrossProcessCompletableController.CompleteCompletableAction
35 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): TextValue { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.ipcActions.ReadTextAction
38 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): IpcUnit { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.ipcActions.SetTextAction
80 it.invokeInRemoteProcess( in createMultiProcessTestDatastore()131 override suspend fun invokeInRemoteProcess(subject: TwoWayIpcSubject): CreateDatastoreAction { in invokeInRemoteProcess() method in androidx.datastore.testapp.multiprocess.ipcActions.CreateDatastoreAction