uw-labs / proximo

Interoperable GRPC based publish/subscribe
GNU Lesser General Public License v3.0
41 stars 16 forks source link

Use error group for consume instead of error channel. #61

Closed SpeedyCoder closed 5 years ago

SpeedyCoder commented 5 years ago

This makes sure that everything shuts down before returning from the function by doing all channel communications in select statements with context. It also handles errors nicely (I updated them to include appropriate gRPC error codes when possible).