Fix comparison to allow item buffers to be filled completely. (#54)

The comparison to buffer capacity should be `>`, not `>=`. The current comparison prevents the item buffers from ever being totally full, which implies that the final shard written from each buffer is smaller than the others by `sender_buffer_size`

Author: macklin-10x

src/lib.rs

@@ -352,15 +352,15 @@ impl<T, H: BufHandler<T>> BufferStateMachine<T, H> {
             let (mut new_state, outcome) = match current_state {
                 FillAndWait(mut f, w) => {
                     f.append(items);
-                    if f.len() + self.sender_buffer_size >= f.capacity() {
+                    if f.len() + self.sender_buffer_size > f.capacity() {
                         (FillAndBusy(w), Process(f))
                     } else {
                         (FillAndWait(f, w), Done)
                     }
                 }
                 FillAndBusy(mut f) => {
                     f.append(items);
-                    if f.len() + self.sender_buffer_size >= f.capacity() {
+                    if f.len() + self.sender_buffer_size > f.capacity() {
                         (BothBusy, Process(f))
                     } else {
                         (FillAndBusy(f), Done)