(_ context.Context, _ string, sinceSeq int64, _ int)
| 57 | } |
| 58 | |
| 59 | func (f *fakeHubClient) ReadConversation(_ context.Context, _ string, sinceSeq int64, _ int) ([]models.ConversationEvent, error) { |
| 60 | f.mu.Lock() |
| 61 | defer f.mu.Unlock() |
| 62 | var out []models.ConversationEvent |
| 63 | for _, ev := range f.events { |
| 64 | if ev.Seq > sinceSeq { |
| 65 | out = append(out, ev) |
| 66 | } |
| 67 | } |
| 68 | return out, nil |
| 69 | } |
| 70 | |
| 71 | func (f *fakeHubClient) SubscribeConversation(ctx context.Context, _ string, _ int64) (<-chan models.ConversationEvent, error) { |
| 72 | out := make(chan models.ConversationEvent) |