Skip to content

Commit d2e7491

Browse files
Add tests (currently failing)
1 parent 3c93b73 commit d2e7491

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

spring-data-cassandra/src/test/java/org/springframework/data/cassandra/repository/aot/CassandraRepositoryContributorIntegrationTests.java

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
import org.springframework.data.cassandra.repository.support.AbstractSpringDataEmbeddedCassandraIntegrationTest;
4646
import org.springframework.data.cassandra.repository.support.IntegrationTestConfig;
4747
import org.springframework.data.domain.Limit;
48+
import org.springframework.data.domain.PageRequest;
4849
import org.springframework.data.domain.Pageable;
4950
import org.springframework.data.domain.ScoringFunction;
5051
import org.springframework.data.domain.Slice;
@@ -203,7 +204,16 @@ void shouldConvertResultToStreamable() {
203204
assertThat(fragment.streamByLastname("White", Sort.by("firstname")))
204205
.isInstanceOf(Streamable.class) //
205206
.extracting(Person::getFirstname) //
206-
.containsSequence("Flynn (Walter Jr.)", "Skyler", "Walter");
207+
.containsExactly("Flynn (Walter Jr.)", "Skyler", "Walter");
208+
}
209+
210+
@Test // GH-1620
211+
void shouldConvertResultToStreamableWhenPageableParameterIsUsed() {
212+
213+
assertThat(fragment.streamByLastname("White", PageRequest.of(0, 2, Sort.by("firstname"))))
214+
.isInstanceOf(Streamable.class) //
215+
.extracting(Person::getFirstname) //
216+
.containsExactly("Flynn (Walter Jr.)", "Skyler");
207217
}
208218

209219
@Test // GH-1566

spring-data-cassandra/src/test/java/org/springframework/data/cassandra/repository/aot/PersonRepository.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,8 @@ public interface PersonRepository extends CrudRepository<Person, String> {
6666

6767
Streamable<Person> streamByLastname(String lastname, Sort sort);
6868

69+
Streamable<Person> streamByLastname(String lastname, Pageable pageable);
70+
6971
List<Person> findByLastnameOrderByFirstnameAsc(String lastname);
7072

7173
Person findByFirstnameStartsWith(String prefix);

0 commit comments

Comments
 (0)