diff --git a/src/client.rs b/src/client.rs
index d61beb2..bfd1e84 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -112,7 +112,7 @@ impl Client {
 	pub async fn join_workspace(&mut self, workspace: &str) -> crate::Result<Arc<Workspace>> {
 		let ws_stream = self.services.workspace.clone().attach(Empty{}.into_request()).await?.into_inner();
 
-		let (tx, rx) = mpsc::channel(10);
+		let (tx, rx) = mpsc::channel(256);
 		let cur_stream = self.services.cursor.clone()
 			.attach(tokio_stream::wrappers::ReceiverStream::new(rx))
 			.await?
diff --git a/src/workspace.rs b/src/workspace.rs
index 86c4301..9c42b23 100644
--- a/src/workspace.rs
+++ b/src/workspace.rs
@@ -94,7 +94,7 @@ impl Workspace {
 		let credentials = worskspace_client.access_buffer(request).await?.into_inner();
 		self.token.send(credentials.token)?;
 
-		let (tx, rx) = mpsc::channel(10);
+		let (tx, rx) = mpsc::channel(256);
 		let mut req = tonic::Request::new(tokio_stream::wrappers::ReceiverStream::new(rx));
 		req.metadata_mut().insert("path", tonic::metadata::MetadataValue::try_from(credentials.id.id).expect("could not represent path as byte sequence"));
 		let stream = self.services.buffer.clone().attach(req).await?.into_inner();