Fixed - RStream.trim method throws exception #2352

redisson/src/main/java/org/redisson/RedissonStream.java

@@ -905,12 +905,12 @@ public class RedissonStream<K, V> extends RedissonExpirable implements RStream<K
 
     @Override
     public RFuture<Long> trimAsync(int count) {
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.XTRIM, "MAXLEN", count);
+        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.XTRIM, getName(), "MAXLEN", count);
     }
 
     @Override
     public RFuture<Long> trimNonStrictAsync(int count) {
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.XTRIM, "MAXLEN", "~", count);
+        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.XTRIM, getName(), "MAXLEN", "~", count);
     }
 
     @Override

redisson/src/test/java/org/redisson/RedissonStreamTest.java

@@ -21,6 +21,17 @@ import org.redisson.client.RedisException;
 
 public class RedissonStreamTest extends BaseTest {
 
+    @Test
+    public void testTrim() {
+        RStream<String, String> stream = redisson.getStream("test");
+
+        stream.add("0", "0");
+        stream.add("1", "1");
+        stream.add("2", "2");
+
+        assertThat(stream.trim(2)).isEqualTo(1);
+    }
+
     @Test
     public void testPendingEmpty() {
         RStream<Object, Object> stream = redisson.getStream("test");