aljaz/lndhub.go
1
1
Fork 0
mirror of https://github.com/getAlby/lndhub.go.git synced 2026-01-05 22:15:50 +01:00
Code Issues Packages Projects Releases Wiki Activity

Create the channels during the Subscribe function call and make them buffered

Browse Source
This commit is contained in:
Lucas Rouckhout
2023-02-18 16:46:56 +01:00
parent 28a4a4d81a
commit 27e67b7d56
4 changed files with 13 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
lib/service/grpc_server.go
View File

@@ -36,8 +36,7 @@ func NewGrpcServer(svc *LndhubService, ctx context.Context) (*Server, error) {
}
func (s *Server) SubsribeInvoices(req *lndhubrpc.SubsribeInvoicesRequest, srv lndhubrpc.InvoiceSubscription_SubsribeInvoicesServer) error {
incomingInvoices := make(chan models.Invoice)
_, err := s.svc.InvoicePubSub.Subscribe(common.InvoiceTypeIncoming, incomingInvoices)
incomingInvoices, _, err := s.svc.InvoicePubSub.Subscribe(common.InvoiceTypeIncoming)
if err != nil {
return err
}