Gets the set of streams declared for the specified component.
433540
public Set<String> getComponentStreams(String componentId) {
    if (outputs.containsKey(componentId)) {
      Set<String> streams = new HashSet<>();
      List<TopologyAPI.OutputStream> olist = outputs.get(componentId);
      for (TopologyAPI.OutputStream ostream : olist) {
        streams.add(ostream.getStream().getId());
      }
      return streams;
    } else {
      return null;
    }
  }
181745
@Override
    public List<org.fcrepo.server.types.gen.Datastream> getDatastreams(String pid,
                                                                       String asOfDateTime,
                                                                       String dsState) {
        assertInitialized();
        try {
            MessageContext ctx = context.getMessageContext();
            org.fcrepo.server.storage.types.Datastream[] intDatastreams =
                    m_management.getDatastreams(ReadOnlyContext
                            .getSoapContext(ctx), pid, DateUtility
                            .parseDateOrNull(asOfDateTime), dsState);
            return getGenDatastreams(intDatastreams);
        } catch (Throwable th) {
            LOG.error("Error getting datastreams", th);
            throw CXFUtility.getFault(th);
        }
    }
1362563
private Stream<Map<Archive, Set<String>>> dependenceStream() {
        return deps.keySet().stream()
                   .filter(source -> !source.getModule().isNamed()
                            || configuration.rootModules().contains(source))
                   .map(deps::get);
    }
837010
static function getRenderingOfSet (array $components = null)
  {
    ob_start (null, 0);
    if (isset($components))
      foreach ($components as $component)
        $component->run ();
    return ob_get_clean ();
  }
223273
def list_streams(region=None, key=None, keyid=None, profile=None):
    '''
    
    '''
    conn = _get_conn(region=region, key=key, keyid=keyid, profile=profile)
    streams = []
    exclusive_start_stream_name = ''
    while exclusive_start_stream_name is not None:
        args = {'ExclusiveStartStreamName': exclusive_start_stream_name} if exclusive_start_stream_name else {}
        ret = _execute_with_retries(conn, 'list_streams', **args)
        if 'error' in ret:
            return ret
        ret = ret['result'] if ret and ret.get('result') else {}
        streams += ret.get('StreamNames', [])
        exclusive_start_stream_name = streams[-1] if ret.get('HasMoreStreams', False) in (True, 'true') else None
    return {'result': streams}
817327
def <<(stream)
      case stream_type(stream)
      when :client then
        return unless stream.connected?
        jid = stream.user.jid.bare
        @clients[jid] ||= []
        @clients[jid] << stream
      when :server then @servers << stream
      when :component then @components << stream
      end
    end
35601
public Set<S> getMatchedDeclarationBinder() {
        Set<S> bindedSet = new HashSet<S>();
        for (Map.Entry<ServiceReference<S>, BinderDescriptor> e : declarationBinders.entrySet()) {
            if (e.getValue().match) {
                bindedSet.add(getDeclarationBinder(e.getKey()));
            }
        }
        return bindedSet;
    }
85718
public Datastream[] getDatastreams(Context context,
                                       String pid,
                                       Date asOfDateTime,
                                       String dsState) throws ServerException {
        return delegate.getDatastreams(context, pid, asOfDateTime, dsState);
    }
887108
public java.util.List<LogStream> getLogStreams() {
        if (logStreams == null) {
            logStreams = new com.amazonaws.internal.SdkInternalList<LogStream>();
        }
        return logStreams;
    }
431699
public Set<PackageResourceReferenceWrapper> getPackageResourceReference(
		final Class<?> componentClass)
	{
		Set<PackageResourceReferenceWrapper> packageResourceReference = PackageResourceReferences
			.getInstance().getPackageResourceReferenceMap().get(componentClass);
		packageResourceReference = addPackageResourceReferenceFromInterfaces(
			packageResourceReference, componentClass);
		return packageResourceReference;
	}
1067154
function getProductsStream (types) {
  var stream = JSONStream.stringify(false);
  this.getProductsLists().then(function (lists) {
    this.getProductsDetails(selectProducts(types, lists), true)
        .pipe(JSONStream.parse())
        .pipe(stream);
  }.bind(this));
  return stream;
}
216054
public Set<Component> getRegisteredComponents() {
      Set<Component> set = new HashSet<>();
      for (ComponentRef<?> c : basicComponentRegistry.getRegisteredComponents()) {
         ComponentMetadata metadata = c.wired() != null ?
                                      componentMetadataRepo.getComponentMetadata(c.wired().getClass()) : null;
         Component component = new Component(c, metadata);
         set.add(component);
      }
      return set;
   }
581637
public SIMPIterator getStreams()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getStreams");
    Iterator it = null;
    try
    {
      it = streamSet.iterator();
    }
    catch (SIResourceException e)
    {
      FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.TargetStreamSetControl.getStreams",
          "1:476:1.16",
          this);
      
        SIMPRuntimeOperationFailedException finalE =
          new SIMPRuntimeOperationFailedException(
            nls.getFormattedMessage(
              "INTERNAL_MESSAGING_ERROR_CWSIP0002",
              new Object[] {"TargetStreamSetControl.getStreams",
                  "1:484:1.16",
                            e},
              null), e);
            
        SibTr.exception(tc, finalE);
//        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "getStreams", finalE);
//        throw finalE;
    }
    TargetStreamControllableIterator targetStreamIterator = 
      new TargetStreamControllableIterator(it, tsm);
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getStreams", targetStreamIterator);      
    return targetStreamIterator;      
  }
904653
@Override
  public Set<ConfigStream> getConfigStreams() throws IOException {
    Set<ConfigStream> configStreams = Sets.newHashSet();
    for (String configPath : getDeployableConfigPaths()) {
      configStreams.add(new ConfigStream(Optional.of(getConfigStream(configPath)),
          StringUtils.substringAfter(Strings.nullToEmpty(configPath), this.classpathRootName + "/")));
    }
    return configStreams;
  }
340033
public Map<String, Map<String, TopologyAPI.Grouping>> getTargets(String componentId) {
    Map<String, Map<String, TopologyAPI.Grouping>> retVal =
        new HashMap<>();
    if (!outputs.containsKey(componentId)) {
      return retVal;
    }
    for (TopologyAPI.OutputStream ostream : outputs.get(componentId)) {
      Map<String, TopologyAPI.Grouping> targetMap =
          new HashMap<>();
      for (Map.Entry<String, List<TopologyAPI.InputStream>> e : inputs.entrySet()) {
        String targetComponentId = e.getKey();
        for (TopologyAPI.InputStream is : e.getValue()) {
          if (areStreamsEqual(ostream.getStream(), is.getStream())) {
            targetMap.put(targetComponentId, is.getGtype());
          }
        }
      }
      retVal.put(ostream.getStream().getId(), targetMap);
    }
    return retVal;
  }
761464
public synchronized List<String> getComponents() {
        List<String> compos = new ArrayList<>();
        for (Map.Entry<String, String> entry : componentVersions.entrySet()) {
            compos.add(entry.getKey());
        }
        return compos;
    }
708524
protected Stream<T> getAll(Connection conn) {
        return executeSelectAsStream(rowMapper, conn, true, calcSqlSelectAll());
    }