Examples { @Procedure(mode = Mode.WRITE) @Description("apoc.example.movies() | Creates the sample movies graph") public Stream<ProgressInfo> movies() { long start = System.currentTimeMillis(); String file = "movies.cypher"; Result result = tx.execute(Util.readResourceFile(file)); QueryStatistics stats = result.getQueryStatistics(); ProgressInfo progress = new ProgressInfo(file, "example movie database from themoviedb.org", "cypher") .update(stats.getNodesCreated(), stats.getRelationshipsCreated(), stats.getPropertiesSet()) .done(start); result.close(); return Stream.of(progress); }  @Procedure(mode = Mode.WRITE) @Description("apoc.example.movies() | Creates the sample movies graph") Stream<ProgressInfo> movies(); @Context
    public Transaction tx; }
@Test public void testMovies() throws Exception { TestUtil.testCall(db,"CALL apoc.example.movies", r -> { assertEquals("movies.cypher",r.get("file")); assertEquals(169L,r.get("nodes")); assertEquals(250L,r.get("relationships")); }); }