List of newStream() Examples

Examples of newStream()

cl.niclabs.skandium.Skandium.newStream()
Factory method is used to create a new {@link Stream}, which in turn can be used to input parameters for computation. @param < P> The type of skeleton program's input. @param < R> The type of the skeleton programs' result. @param skeleton The skeleton program which will be used to compute each parameter entered through the {@link Stream}. @return A new {@link Stream} associated with the specified {@link cl.niclabs.skandium.skeletons.Skeleton} program.
javax.mail.internet.SharedInputStream.newStream()
javax.mail.util.SharedFileInputStream.newStream()
Return a new InputStream representing a subset of the data from this InputStream, starting at start (inclusive) up to end (exclusive). start must be non-negative. If end is -1, the new stream ends at the same place as this stream. The returned InputStream will also implement the SharedInputStream interface. @param start the starting position @param end the ending position + 1 @return the new stream
org.eclipse.jetty.http2.HTTP2Session.newStream()
org.eclipse.jetty.http2.api.Session.newStream()
storm.trident.TridentTopology.newStream()

Examples of cl.niclabs.skandium.Skandium.newStream()

  @Override
  public Future<R> input(P param){
    
    Skandium skandium = Skandium.getSingleton();
    
    Stream<P,R> stream = skandium.newStream(this);
    
    return stream.input(param);
  }
  
  /**

View Full Code Here

Examples of cl.niclabs.skandium.Skandium.newStream()

   */
  @Override
  public Future<R>[] input(P param[]){
    Skandium skandium = Skandium.getSingleton();
    
    Stream<P,R> stream = skandium.newStream(this);
    
    return stream.input(param);
  }
  
  /**

View Full Code Here

Examples of cl.niclabs.skandium.Skandium.newStream()

    Skeleton<Interval, BigDecimal> pi = new Map<Interval, BigDecimal>(
        new SplitInterval(PARTS), //number of parts to divide by
        new PiComputer(),
        new MergeResults());


    Stream<Interval, BigDecimal> stream = skandium.newStream(pi);
    
    // 2. Input parameters with the defauls singleton Skandium object
        long init = System.currentTimeMillis();
    Future<BigDecimal> future = stream.input(new Interval(0, DECIMALS));

View Full Code Here

Examples of cl.niclabs.skandium.Skandium.newStream()

       
       //2. Create a new Skandium instance with 2 execution threads
         Skandium skandium = new Skandium(THREADS);


         //3. Open a Stream to input parameters
         Stream<Board, Count> stream = skandium.newStream(nqueens);
         
         //4. Input parameters
         long init = System.currentTimeMillis();
         Future<Count> future = stream.input(new Board(BOARD));

View Full Code Here

Examples of cl.niclabs.skandium.Skandium.newStream()

       
       //2. Create a new Skandium instance
         Skandium skandium = new Skandium(THREADS);


         //3. Open a Stream to input parameters
         Stream<Operands, Matrix> stream = skandium.newStream(multiply);


         //4. Input parameters
         long init = System.currentTimeMillis();
         Future<Matrix> future = stream.input(new Operands(newRandomMatrix(SIZE), newRandomMatrix(SIZE)));

View Full Code Here

Examples of cl.niclabs.skandium.Skandium.newStream()

        new Sort(),
        new MergeList());


    Skandium skandium = new Skandium(THREADS);
    
    Stream<Range, Range> stream = skandium.newStream(sort);
    
    // 2. Input parameters with the defaults singleton Skandium object
      long init = System.currentTimeMillis();
      
    Future<Range> future = stream.input(new Range(generate(SIZE),0, SIZE-1));

View Full Code Here

Examples of javax.mail.internet.SharedInputStream.newStream()

            synchronized (this) {
                if (contentStream == null) {
                    InputStream stream = connection.getInputStream(this);
                    headers = new InternetHeaders(stream);
                    SharedInputStream shared = (SharedInputStream) stream;
                    contentStream = shared.newStream(shared.getPosition(), -1l);
                    stream = null;
                }
                return super.getContentStream();
            }
        } catch (MessagingException ex) {

View Full Code Here

Examples of javax.mail.util.SharedFileInputStream.newStream()

            config.setMaximalBodyDescriptor(true);
            config.setMaxLineLen(-1);
            final ConfigurableMimeTokenStream parser = new ConfigurableMimeTokenStream(config);


            parser.setRecursionMode(MimeTokenStream.M_NO_RECURSE);
            parser.parse(tmpMsgIn.newStream(0, -1));


            int next = parser.next();
            while (next != MimeTokenStream.T_BODY && next != MimeTokenStream.T_END_OF_STREAM && next != MimeTokenStream.T_START_MULTIPART) {
                next = parser.next();
            }

View Full Code Here

Examples of org.eclipse.jetty.http2.HTTP2Session.newStream()

        HttpFields fields = new HttpFields();
        MetaData.Request metaData = newRequest("GET", fields);
        HeadersFrame frame1 = new HeadersFrame(1, metaData, null, false);
        FuturePromise<Stream> streamPromise1 = new FuturePromise<>();
        final CountDownLatch responseLatch = new CountDownLatch(1);
        session.newStream(frame1, streamPromise1, new Stream.Listener.Adapter()
        {
            @Override
            public void onHeaders(Stream stream, HeadersFrame frame)
            {
                if (frame.isEndStream())

View Full Code Here

Examples of org.eclipse.jetty.http2.HTTP2Session.newStream()


        Stream stream1 = streamPromise1.get(5, TimeUnit.SECONDS);


        HeadersFrame frame2 = new HeadersFrame(3, metaData, null, false);
        FuturePromise<Stream> streamPromise2 = new FuturePromise<>();
        session.newStream(frame2, streamPromise2, new Stream.Listener.Adapter());


        streamPromise2.get(5, TimeUnit.SECONDS);
        Assert.assertTrue(resetLatch.await(5, TimeUnit.SECONDS));


        stream1.data(new DataFrame(stream1.getId(), BufferUtil.EMPTY_BUFFER, true), new Callback.Adapter());

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.