Examples of source()

Examples of java.nio.channels.Pipe.source()

71
72
73
74
75
76
77
78
79
80
81
        // Now construct the output pipeline to process the data
        //
       
        Element src = null;
        try {           
            src = new ReadableByteChannelSrc(pipeChannel.source(), "input file");
        } catch (Exception ex) {
            ex.printStackTrace();
            throw new RuntimeException(ex);
        }
       
View Full Code Here

Examples of java.nio.channels.Pipe.source()

82
83
84
85
86
87
88
89
90
91
92
  @Test
  public void testSocketIOWithTimeout() throws Exception {
   
    // first open pipe:
    Pipe pipe = Pipe.open();
    Pipe.SourceChannel source = pipe.source();
    Pipe.SinkChannel sink = pipe.sink();
   
    try {
      final InputStream in = new SocketInputStream(source, TIMEOUT);
      OutputStream out = new SocketOutputStream(sink, TIMEOUT);
View Full Code Here

Examples of java.nio.channels.Pipe.source()

3577
3578
3579
3580
3581
3582
3583
3584
3585
3586
3587
                                                            autoStartBuffer);

    //commn channels between reader and writer
    Pipe pipe = Pipe.open();
    Pipe.SinkChannel writerStream = pipe.sink();
    Pipe.SourceChannel readerStream = pipe.source();
    writerStream.configureBlocking(true);
    readerStream.configureBlocking(false);

    //Event writer - Relay in the real world
    int batchSize = input.getBatchSize() * eventSize;
 
View Full Code Here

Examples of net.kuujo.vertigo.io.connection.OutputConnectionContext.source()

111
112
113
114
115
116
117
118
119
120
121
  @Override
  public String toString() {
    if (!connections.isEmpty()) {
      OutputConnectionContext context = connections.get(0);
      return String.format("Stream[%s:%s->%s:%s]", context.source().component(), context.source().port(), context.target().component(), context.target().port());
    }
    return "Stream[?]";
  }

  /**
 
View Full Code Here

Examples of net.kuujo.vertigo.io.connection.OutputConnectionContext.source()

111
112
113
114
115
116
117
118
119
120
121
  @Override
  public String toString() {
    if (!connections.isEmpty()) {
      OutputConnectionContext context = connections.get(0);
      return String.format("Stream[%s:%s->%s:%s]", context.source().component(), context.source().port(), context.target().component(), context.target().port());
    }
    return "Stream[?]";
  }

  /**
 
View Full Code Here

Examples of net.sourceforge.javautil.database.encryption.annotation.EncryptionConfig.source()

140
141
142
143
144
145
146
147
148
149
150
      if (provider != null) return provider;
    }
   
    EncryptionConfig config = clazz.getAnnotation(EncryptionConfig.class);
    byte[] key = null;
    if (config != null && config.source() == Source.PASSWORD_LOCKER) {
      if ("".equals( config.sourceName() )) throw new IllegalArgumentException("Password locker source name must be provider for: " + clazz);
      if (PasswordContext.get() == null) throw new IllegalStateException("No password locker available for the current context");
     
      IPassword pw = PasswordContext.get().getPassword(config.sourceName());
      if (pw == null) throw new IllegalArgumentException("No such password in current context locker: " + config.sourceName());
View Full Code Here

Examples of net.yacy.document.importer.OAIPMHLoader.source()

64
65
66
67
68
69
70
71
72
73
74
                    url = new DigestURI(oaipmhurl);
                    OAIPMHLoader r = new OAIPMHLoader(sb.loader, url, sb.surrogatesInPath, "oaipmh-one");
                    ResumptionToken rt = r.getResumptionToken();
                    prop.put("import-one", 1);
                    prop.put("import-one_count", (rt == null) ? "not available" : Integer.toString(rt.getRecordCounter()));
                    prop.put("import-one_source", r.source());
                    prop.put("import-one_rt", r.getResumptionToken().toString());
                   
                    // set next default url
                    try {
                        DigestURI nexturl = (rt == null) ? null : rt.resumptionURL();
View Full Code Here

Examples of org.apache.any23.extractor.html.HTMLDocument.TextField.source()

149
150
151
152
153
154
155
156
157
158
159
        for (Node rule : compoNode.findAllByClassName("rrule")) {
            BNode rrule = valueFactory.createBNode();
            addURIProperty(rrule, RDF.TYPE, vICAL.DomainOf_rrule);
            TextField freq = new HTMLDocument(rule).getSingularTextField("freq");
            conditionallyAddStringProperty(
                    freq.source(),
                    rrule, vICAL.freq, freq.value()
            );
            addBNodeProperty(
                    rule,
                    evt, vICAL.rrule, rrule
View Full Code Here

Examples of org.apache.any23.extractor.html.HTMLDocument.TextField.source()

348
349
350
351
352
353
354
355
356
357
358
                }
            } else {
                TextField value =  name.getField(fieldName);
                if(value == null) { continue; }
                addFieldTriple(
                        value.source(),
                        n, fieldName, value.value()
                );
            }
        }
        return true;
View Full Code Here

Examples of org.apache.any23.extractor.html.HTMLDocument.TextField.source()

366
367
368
369
370
371
372
373
374
375
376
        final TextField fullNameTextField = name.getFullName();
        if(fullNameTextField == null) {
            return false;
        }
        return conditionallyAddStringProperty(
                fullNameTextField.source(),
                card, vCARD.fn, fullNameTextField.value()
        );
    }

    private void readOrganization() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.