(t *testing.T)
| 226 | |
| 227 | |
| 228 | func TestGetSyncOne(t *testing.T) { |
| 229 | chV := make(chan []string) |
| 230 | chRev := make(chan int64) |
| 231 | st := New() |
| 232 | defer close(st.Ops) |
| 233 | go func() { |
| 234 | sync(st, 5) |
| 235 | v, rev := st.Get("/x") |
| 236 | chV <- v |
| 237 | chRev <- rev |
| 238 | }() |
| 239 | st.Ops <- Op{1, MustEncodeSet("/x", "a", Clobber)} |
| 240 | st.Ops <- Op{2, MustEncodeSet("/x", "a", Clobber)} |
| 241 | st.Ops <- Op{3, MustEncodeSet("/x", "a", Clobber)} |
| 242 | st.Ops <- Op{4, MustEncodeSet("/x", "a", Clobber)} |
| 243 | st.Ops <- Op{5, MustEncodeSet("/x", "b", Clobber)} |
| 244 | sync(st, 5) |
| 245 | assert.Equal(t, []string{"b"}, <-chV) |
| 246 | assert.Equal(t, int64(5), <-chRev) |
| 247 | } |
| 248 | |
| 249 | func TestGetSyncSeveral(t *testing.T) { |
| 250 | chV := make(chan []string) |
nothing calls this directly
no test coverage detected