标签: stream

我有listData (List<String>)一个getList接受String作为参数的方法(例如"java")并返回一个List<String>(例如["j","a","v","a"]).我需要将这些列表收集到一个列表中.我试过了addAll,它工作正常:

List<String> listData = Arrays.asList("java","Stream","laMbdA");
List<String> resultList = new ArrayList<>();

listData.stream()
        .map(this::getList)  // acccepts String as an argument and returns List<String>
        .forEach(resultList::addAll);

如果我尝试Collectors.toList(),我会得到一个List<List<String>>

 listData.stream()
         .map(this::getList)
         .collect(Collectors.toList());

有什么方法Collectors可以代替addAll吗？

我正在尝试制作一个超压缩的brainfuck变种,这是一种带有8条指令的深奥编程语言.由于3位是存储8个值的最小存储量,所以我选择了它.我坚持的部分是如何读取不是2的幂的位数.

我尝试使用std::bitset,但这只是序列化为每位1字节的字符串,这与我想要的相反.我该怎么做？

在发布此问题之前,我已经完成了我的研究,并确保没有提出类似的问题.

我正在阅读这篇文章http://www.ntu.edu.sg/home/ehchua/programming/cpp/cp10_io.html关于C++中的流,并且我在蓝色中注意到的链接图中有basic_iostream,在它下面绿色是iostream,basic_ifstream和ifstream等同样如此,

从我读到的是basic_iostream是一个模板类,iostream是basic_iostream的实例,但这是什么意思？

iostream不是像cout,cin和cerr这样的对象,那么它是如何实例化的呢？

C++ 有没有办法定义一个函数，这样我就可以做这样的事情：

foo( "Error on line " << iLineNumber );
foo( "name " << strName << " is Invalid" );

就像现在一样，我必须在调用 foo 函数之前声明一个 ostringstream 对象，如下所示：

std::ostringstream strStream1;
ostringstream1 << "Error on line " << iLineNumber;
foo( ostringstream1 );

std::ostringstream strStream2;
ostringstream2 << "name " << strName << " is Invalid";
foo( ostringstream2 );

我需要为IOS找到以下代码的等效项。

byte[] encodedMess;
using (var stream = new MemoryStream())
  {
    using (var writer = new BinaryWriter(stream))
    {
       writer.Write(message.getType().ToString();
       writer.Write(message.toJSONString());
    }
    encodedMess = stream.ToArray();
  } 

我已经尝试了一些技巧并在互联网上找到短裤代码，但没有任何效果:(

你是我最后的机会......我必须有一个像encodedMess这样的字节数组......

感谢每一个帮助（对不起，我的英语不好）

我在Windows窗体应用程序中的Timer有问题.需要Timer记录归档时间的归档程序.然而有什么东西打断了计时器？

我怀疑是流.关于什么可能导致计时器中断的任何建议？

public partial class Form1 : Form
{
    int timerCounter = 0;
    System.Windows.Forms.Timer timer = new System.Windows.Forms.Timer();

    public Form1()
    {
        InitializeComponent();
        timer.Interval = 1000; 
        timer.Enabled = true;
    }

    public void button2_Click(object sender, EventArgs e)
    {
        timer.Start();
        timer.Tick += new EventHandler(timer1_Tick); 

        // code for archiving, streams

        timer.Stop(); 

        MessageBox.Show("Archive was created! :)");
    }

    public void timer1_Tick(object sender, EventArgs e)
    {
        this.label7.Text = (++timerCounter).ToString();
    }  

}

给定一个包含字符串"Hello World"的文件(注意'Hello'和'World'之间有一个空格).

int main()
{
    ofstream fout("test.txt");
    fout.write("Hello World", 12);
    fout.close();

    ifstream fin("test.txt");
    vector<string> coll((istream_iterator<string>(fin)),
                        (istream_iterator<string>()));
    // coll contains two strings 'Hello' and 'World' rather than 
    // one string "Hello World" that is just I want.
}

换句话说,我希望istream中的字符串只能用'\n'而不是'','\n'等分隔.

我应该怎么做？

我正在尝试编写一个名为的模板化函数unique()，该函数std::vector仅使用<vector>,<set>和<iostream>标头来检测 a 是否只有唯一元素。

template <typename T>
bool unique(const std::vector<T>& container){}

我怎样才能做到这一点？

要过滤List我们可以使用

a1.stream().filter(x->x>6).forEach(System.out::println);

并过滤我使用的两个列表 FlatMap

Stream<List<Integer>> s2=Stream.of(a1,a2);
s2.flatMap(x->x.stream()).sorted().filter(x->x>6).forEach(System.out::println);

但我尝试以这种方式过滤单个 List

Stream<List<Integer>> s1=Stream.of(a1);
s1.map(x->x.stream()).filter(x->x>2).forEach(System.out::print);

我有一个错误--- The operator > is undefined for the argument type(s) Stream<Integer>, int

但是当我在地图中使用 flatMap 时没有错误为什么

Stream<List<Integer>> s1=Stream.of(a1); 
s1.flatMap(x->x.stream()).filter(x->x>2).forEach(System.out::print);

我正在尝试将下载的所有字节写入3个不同的文件,现在,我正在使用WebRequest和WebResponse对象.我确定它是正确的方法吗？我陷入了将数据写入部分文件的部分困难.无论写入什么数据,目前的目标是从同一个流中读取数据并将其写入3个不同的文件.我可以成功写入第一个文件,而不是它给出错误 - 当我尝试将流(我从response.getResponseStream()获取)分配给另一个二进制读取器时,流不可读.

我尝试过两种方法 - 一种是直接将响应流传递给不同的二进制读取器,失败了.其次,我尝试为每个二进制读取器创建separte引用,但也失败了.这是代码,如果它可以帮助: -

using (Stream strm = res.GetResponseStream())
{
    using (Stream strm1 = strm)
    {
        int i = 0;
        BinaryReader br = new BinaryReader(strm1);
        br.BaseStream.BeginRead(buffer, 0, buffer.Length, 
            new AsyncCallback(ProcessDnsInformation), br);
        Console.WriteLine("Data read {0} times", i++);
        Console.ReadKey();
        File.WriteAllBytes(@"C:\Users\Vishal Sheokand\Desktop\Vish.bin", buffer);
        br.Close();
    }

    using (Stream strm2=strm)
    {
        int i = 0;
        BinaryReader br = new BinaryReader(strm2);
        br.BaseStream.BeginRead(buffer, 0, buffer.Length, 
            new AsyncCallback(ProcessDnsInformation), br);
        Console.WriteLine("Data read {0} times", i++);
        Console.ReadKey();
        File.WriteAllBytes(@"C:\Users\Vishal Sheokand\Desktop\Vish1.bin", buffer);
        br.Close();
    }

    using (Stream strm3 = strm) …