| package chunk |
| |
| import ( |
| "bytes" |
| "testing" |
| ) |
| |
| func TestConcurrentReads(t *testing.T) { |
| c := InMemoryChunkFactory{}.New(4) |
| if _, err := c.WriterAt().WriteAt([]byte("abcd"), 0); err != nil { |
| panic(err) |
| } |
| d1 := make([]byte, 2) |
| d2 := make([]byte, 3) |
| if _, err := c.ReaderAt().ReadAt(d1, 0); err != nil { |
| t.Error(err) |
| } |
| if bytes.Compare(d1, []byte("ab")) != 0 { |
| t.Errorf("Expected: %s\nActual: %s", "ab", d1) |
| } |
| if _, err := c.ReaderAt().ReadAt(d2, 0); err != nil { |
| t.Error(err) |
| } |
| if bytes.Compare(d2, []byte("abc")) != 0 { |
| t.Errorf("Expected: %s\nActual: %s", "abc", d2) |
| } |
| } |