demdxx / asyncp / 10830267712

coverage: 44.123% (-23.4%) from 67.562%
10830267712

push

github

demdxx 
Add "chan" default stream subscriber

0 of 4 new or added lines in 1 file covered. (0.0%)

931 of 2110 relevant lines covered (44.12%)

0.5 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0
/streams/gochan.go
1 
package streams
2 









3



import (










4



        "context"










5



        "runtime"










6












7



        nc "github.com/geniusrabbit/notificationcenter/v2"










8



        "github.com/geniusrabbit/notificationcenter/v2/gochan"










9



)










10













NEW


11



func init() {




×








NEW


12



        proxy := gochan.New(max(runtime.NumCPU(), 1))




×








NEW


13



        subscribers["gochan"] = func(ctx context.Context, url string) (nc.Subscriber, error) { return proxy, nil }




×








NEW


14



        subscribers["chan"] = subscribers["gochan"]




×







15



}
























    

  • 

    •