Home
last modified time | relevance | path

Searched refs:UIInboxLoader (Results 1 – 12 of 12) sorted by relevance

/dports/security/keybase/client-v5.7.1/go/chat/
H A Duiinboxloader.go24 type UIInboxLoader struct { struct
53 func NewUIInboxLoader(g *globals.Context) *UIInboxLoader {
58 return &UIInboxLoader{
69 func (h *UIInboxLoader) Start(ctx context.Context, uid gregor1.UID) { argument
87 func (h *UIInboxLoader) Stop(ctx context.Context) chan struct{} { argument
151 func (h *UIInboxLoader) flushConvBatch() (err error) { argument
233 func (h *UIInboxLoader) flushFailed(r failedResponse) { argument
252 func (h *UIInboxLoader) transmitOnce(imsg interface{}) { argument
367 func (h *UIInboxLoader) Query() chat1.GetInboxLocalQuery { argument
606 func (h *UIInboxLoader) layoutLoop(shutdownCh chan struct{}) error { argument
[all …]
H A Duiinboxloader_test.go28 tc.ChatG.UIInboxLoader = NewUIInboxLoader(tc.Context())
29 tc.ChatG.UIInboxLoader.Start(ctx, uid)
30 defer func() { <-tc.ChatG.UIInboxLoader.Stop(ctx) }()
31 tc.ChatG.UIInboxLoader.(*UIInboxLoader).testingLayoutForceMode = true
32 tc.ChatG.UIInboxLoader.(*UIInboxLoader).batchDelay = time.Hour
196 tc.ChatG.UIInboxLoader = NewUIInboxLoader(tc.Context())
197 tc.ChatG.UIInboxLoader.Start(ctx, uid)
198 defer func() { <-tc.ChatG.UIInboxLoader.Stop(ctx) }()
199 tc.ChatG.UIInboxLoader.(*UIInboxLoader).testingLayoutForceMode = true
200 tc.ChatG.UIInboxLoader.(*UIInboxLoader).batchDelay = time.Hour
H A Dinboxsource_test.go181 ctc.world.Tcs[users[0].Username].ChatG.UIInboxLoader = types.DummyUIInboxLoader{}
H A Dserver_test.go471 g.UIInboxLoader = types.DummyUIInboxLoader{}
942 tc.ChatG.UIInboxLoader.Start(ctx, uid)
943 defer func() { <-tc.ChatG.UIInboxLoader.Stop(ctx) }()
953 oldUILoader := tc.ChatG.UIInboxLoader
954 tc.ChatG.UIInboxLoader = types.DummyUIInboxLoader{}
986 tc.ChatG.UIInboxLoader = oldUILoader
1095 tc.ChatG.UIInboxLoader.Start(ctx, uid)
1096 defer func() { <-tc.ChatG.UIInboxLoader.Stop(ctx) }()
3988 tc.ChatG.UIInboxLoader.Start(ctx, uid)
3989 defer func() { <-tc.ChatG.UIInboxLoader.Stop(ctx) }()
[all …]
H A Dinboxsource.go549 …s.G().UIInboxLoader.UpdateLayout(ctx, chat1.InboxLayoutReselectMode_DEFAULT, "InboxSource#maybeNuk…
556 storage.LayoutChangedNotifier(s.G().UIInboxLoader))
1309 s.G().UIInboxLoader.UpdateLayout(ctx, chat1.InboxLayoutReselectMode_DEFAULT, "inbox error")
H A Dserver.go166 h.G().UIInboxLoader.UpdateLayout(ctx, reselectMode, "UI request")
179 if err := h.G().UIInboxLoader.UpdateConvs(ctx, convIDs); err != nil {
188 h.G().UIInboxLoader.UpdateLayoutFromSmallIncrease(ctx)
195 h.G().UIInboxLoader.UpdateLayoutFromSmallReset(ctx)
214 if err := h.G().UIInboxLoader.LoadNonblock(ctx, arg.Query, arg.MaxUnbox,
H A Dconvsource.go504 …s.G().UIInboxLoader.UpdateLayout(ctx, chat1.InboxLayoutReselectMode_DEFAULT, "ConvSource#maybeNuke…
H A Dsender_test.go325 g.UIInboxLoader = types.DummyUIInboxLoader{}
/dports/security/keybase/client-v5.7.1/go/chat/globals/
H A Dglobals.go45 UIInboxLoader types.UIInboxLoader // manages loading inbox for UI member
83 UIInboxLoader: %v,
118 c.UIInboxLoader != nil,
/dports/security/keybase/client-v5.7.1/go/service/
H A Dmain.go435 g.UIInboxLoader.Start(context.Background(), uid)
454 <-d.ChatG().UIInboxLoader.Stop(m.Ctx())
539 g.UIInboxLoader = chat.NewUIInboxLoader(g)
/dports/security/keybase/client-v5.7.1/go/kbtest/
H A Dchat.go76 if c.ChatG.UIInboxLoader != nil {
77 <-c.ChatG.UIInboxLoader.Stop(context.TODO())
/dports/security/keybase/client-v5.7.1/go/chat/types/
H A Dinterfaces.go585 type UIInboxLoader interface { interface