This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from dd675df Merge pull request #4807 from udim/pubsub-protobuf
add 070109d Add an InProcess SdkHarness Rule
add 4cba6ac Close Outstanding Control Clients on Service close
add 18e0b4d Don't try to close a cancelled Multiplexer
add 8ac47d9 fixup! Close Outstanding Control Clients on Service close
add 452471a fixup! Don't try to close a cancelled Multiplexer
add 0bda8d9 fixup! Add an InProcess SdkHarness Rule
add eaf0e64 fixup! Don't try to close a cancelled Multiplexer
new e7f3d8b [BEAM-3326] Add an InProcess SdkHarness Rule
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../control/FnApiControlClientPoolService.java | 19 +++-
.../runners/fnexecution/data/GrpcDataService.java | 31 +++---
.../runners/fnexecution/InProcessSdkHarness.java | 113 +++++++++++++++++++++
.../control/FnApiControlClientPoolServiceTest.java | 58 ++++++++++-
.../fnexecution/control/SdkHarnessClientTest.java | 55 ++--------
5 files changed, 211 insertions(+), 65 deletions(-)
create mode 100644
runners/java-fn-execution/src/test/java/org/apache/beam/runners/fnexecution/InProcessSdkHarness.java
--
To stop receiving notification emails like this one, please contact
lc...@apache.org.
