source-sse

Server-sent events source type

grpcurl \
  -plaintext \
  -proto api/grpc/service.proto \
  -d @ \
  localhost:50051 \
  awakari.source.sse.Service/Create

{
  "url": "https://stream.wikimedia.org/v2/stream/recentchange",
  "groupId": "default"
}

grpcurl \
  -plaintext \
  -proto api/grpc/service.proto \
  -d @ \
  localhost:50051 \
  awakari.source.sse.Service/Delete

{
  "url": "https://stream.wikimedia.org/v2/stream/recentchange",
  "groupId": "default"
}