tree 814c86b10c6c4eb8b7e462d95fa6fbe4ef4aab61
parent efb4b6010cd8c1c9e0906d1d64a19134fb20a9e9
author dpcollins-google <40498610+dpcollins-google@users.noreply.github.com> 1631298621 -0400
committer GitHub <noreply@github.com> 1631298621 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJhO6Q9CRBK7hj4Ov3rIwAASREIAJJyiBuUy9Lua55QY8ui7w0G
 xFonrqUK/KEdz20jI5340wn3Alm7MjsFOB/UBJJjm1OxKwEO1UNLE5IcIx7dsXn6
 XbnGwqH5qyfL+s/gbDLHdbX+a1M/WDbtvufPwHKXqLwf3bBUJVJmmqmevsVH0lpV
 cjHhPX9I6lvmEaERLYvHjeS6C6VsB2yV+OfJ9LMf0fUzh3cyI1i0JCitkCP/STcl
 +TUKL3leTKgZYv5NMxZ6P3YlRPsC6uj6iS6WEjzxVNz6O2NRHDMGa1Y1jG+9vHTK
 MWIGhOoUtAc6s4XTGfVEzzRgtqRbIi/6zmfyr9n6U/UnW8yWsedHN1a3DiZaAbo=
 =VBWw
 -----END PGP SIGNATURE-----
 

Port changes from Pub/Sub Lite to beam (#15418)

* Port all changes from the Pub/Sub Lite repo back to beam.

Beam will be the canonical source for this IO in the future per offline discussion.

Also add the other direction of helper to CloudPubsubTransforms and add an integration test.

* remove fixed TODO

* Fixes to ReadWriteIT to work around Create or DirectRunner bug.

* fix racy test